From 712e9da60bcc6c5ba869ba1987b496a25c897b72 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Konstantin=20Gru=CC=88ndger?= Date: Sun, 24 Mar 2019 08:59:57 +0100 Subject: [PATCH] Update receivers/devices with stats --- ogn_python/collect/celery.py | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/ogn_python/collect/celery.py b/ogn_python/collect/celery.py index 2e5928a..c280cc1 100644 --- a/ogn_python/collect/celery.py +++ b/ogn_python/collect/celery.py @@ -10,7 +10,7 @@ from ogn_python.collect.logbook import update_max_altitudes as logbook_update_ma from ogn_python.collect.database import import_ddb as device_infos_import_ddb from ogn_python.collect.database import update_country_code as receivers_update_country_code -from ogn_python.collect.stats import create_device_stats, update_device_stats_jumps, create_receiver_stats, create_relation_stats, update_qualities +from ogn_python.collect.stats import create_device_stats, update_device_stats_jumps, create_receiver_stats, create_relation_stats, update_qualities, update_receivers_command, update_devices_command from ogn_python import db from ogn_python import celery @@ -76,7 +76,7 @@ def purge_old_data(max_hours): @celery.task(name='update_stats') def update_stats(day_offset): - """Update stats of the current day.""" + """Create stats and update receivers/devices with stats.""" date = datetime.datetime.today() + datetime.timedelta(days=day_offset) @@ -84,4 +84,6 @@ def update_stats(day_offset): update_device_stats_jumps(session=db.session, date=date) create_receiver_stats(session=db.session, date=date) create_relation_stats(session=db.session, date=date) - update_qualities(session=db.session, date=date) \ No newline at end of file + update_qualities(session=db.session, date=date) + update_receivers_command(session=db.session) + update_devices_command(session=db.session)