mirror
/
ogn-python
kopia lustrzana https://github.com/glidernet/ogn-python
1
0
Forkuj 0
Kod Zgłoszenia Projekty Wydania Wiki Aktywność

Update celery tasks

pull/68/head
Konstantin Gründger 2017-12-17 14:34:14 +01:00
rodzic f829c9996a
commit 6097a3b840
2 zmienionych plików z 21 dodań i 9 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

26
config/default.py
Wyświetl plik

@ -11,20 +11,28 @@ CELERYBEAT_SCHEDULE = {
'task': 'ogn.collect.database.import_ddb', 'task': 'ogn.collect.database.import_ddb',
'schedule': timedelta(minutes=15), 'schedule': timedelta(minutes=15),
}, },
'update-device-table': {
'task': 'ogn.collect.database.update_devices',
'schedule': timedelta(minutes=5),
},
'update-receiver-table': {
'task': 'ogn.collect.database.update_receivers',
'schedule': timedelta(minutes=5),
},
'update-country-codes': {
'task': 'ogn.collect.database.update_country_code',
'schedule': timedelta(minutes=5),
},
'update-takeoff-and-landing': { 'update-takeoff-and-landing': {
'task': 'ogn.collect.logbook.compute_takeoff_and_landing', 'task': 'ogn.collect.takeoff_landing.update_takeoff_landing',
'schedule': timedelta(minutes=15), 'schedule': timedelta(minutes=15),
}, },
'update-logbook': { 'update-logbook': {
'task': 'ogn.collect.logbook.compute_logbook', 'task': 'ogn.collect.logbook.update_logbook',
'schedule': timedelta(minutes=1), 'schedule': timedelta(minutes=15),
}, },
'update-altitudes': { 'update-max-altitudes': {
'task': 'ogn.collect.logbook.compute_altitudes', 'task': 'ogn.collect.logbook.update_max_altitude',
'schedule': timedelta(minutes=1),
},
'update-receiver-table': {
'task': 'ogn.collect.receiver.update_receivers',
'schedule': timedelta(minutes=15), 'schedule': timedelta(minutes=15),
}, },
} }

4
ogn/collect/database.py
Wyświetl plik

@ -38,6 +38,8 @@ def import_ddb(session=None):
counter = update_device_infos(session, address_origin) counter = update_device_infos(session, address_origin)
logger.info("Imported {} devices.".format(counter)) logger.info("Imported {} devices.".format(counter))
return "Imported {} devices.".format(counter)
@app.task @app.task
def import_file(session=None, path='tests/custom_ddb.txt'): def import_file(session=None, path='tests/custom_ddb.txt'):
@ -52,6 +54,8 @@ def import_file(session=None, path='tests/custom_ddb.txt'):
counter = update_device_infos(session, address_origin, csvfile=path) counter = update_device_infos(session, address_origin, csvfile=path)
logger.info("Imported {} devices.".format(counter)) logger.info("Imported {} devices.".format(counter))
return "Imported {} devices.".format(counter)
@app.task @app.task
def update_devices(session=None): def update_devices(session=None):