2017-03-31 02:32:03 -06:00
|
|
|
from __future__ import absolute_import
|
|
|
|
|
|
|
|
import os
|
|
|
|
|
|
|
|
from celery import Celery
|
2019-04-27 04:56:53 -06:00
|
|
|
from django.conf import settings # noqa
|
2017-03-31 02:32:03 -06:00
|
|
|
|
2017-05-08 08:29:56 -06:00
|
|
|
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'db.settings')
|
2017-03-31 02:32:03 -06:00
|
|
|
|
2018-08-18 18:43:02 -06:00
|
|
|
RUN_EVERY_15 = 60 * 15
|
2017-11-13 03:27:11 -07:00
|
|
|
RUN_HOURLY = 60 * 60
|
2017-03-31 02:32:03 -06:00
|
|
|
RUN_DAILY = 60 * 60 * 24
|
|
|
|
|
|
|
|
app = Celery('db')
|
|
|
|
|
|
|
|
app.config_from_object('django.conf:settings', namespace='CELERY')
|
|
|
|
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)
|
|
|
|
|
|
|
|
|
|
|
|
@app.on_after_finalize.connect
|
|
|
|
def setup_periodic_tasks(sender, **kwargs):
|
2019-01-06 10:34:10 -07:00
|
|
|
from db.base.tasks import update_all_tle, background_cache_statistics, decode_recent_data
|
2017-03-31 02:32:03 -06:00
|
|
|
|
2019-04-27 03:04:49 -06:00
|
|
|
sender.add_periodic_task(RUN_DAILY, update_all_tle.s(), name='update-all-tle')
|
2017-05-31 12:18:03 -06:00
|
|
|
|
2019-04-27 03:04:49 -06:00
|
|
|
sender.add_periodic_task(
|
|
|
|
RUN_HOURLY, background_cache_statistics.s(), name='background-cache-statistics'
|
|
|
|
)
|
2018-08-18 18:43:02 -06:00
|
|
|
|
2019-04-27 03:04:49 -06:00
|
|
|
sender.add_periodic_task(RUN_EVERY_15, decode_recent_data.s(), name='decode-recent-data')
|