from celery.schedules import crontab


# uses AWS creds from the AWS_ACCESS_KEY_ID and AWS_SECRET_ACCESS_KEY env variables
BROKER_URL = 'sqs://'
BROKER_TRANSPORT_OPTIONS = {
    'region': 'eu-west-1',
    'polling_interval': 15 * 1,
    'queue_name_prefix': 'mma-dexter-',
    'visibility_timeout': 3600*12,
}


# all our tasks can by retried if the worker fails
CELERY_ACKS_LATE = True
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
CELERY_ACCEPT_CONTENT = ['json']
CELERY_TIMEZONE = 'Africa/Johannesburg'
CELERY_ENABLE_UTC = True

CELERYBEAT_SCHEDULE = {
    'fetch-yesterdays-feeds': {
        'schedule': crontab(hour=2, minute=0),
        'task': 'dexter.tasks.fetch_yesterdays_feeds',
    },
    'back-process-feeds': {
        'schedule': crontab(hour=11, minute=0),
        'task': 'dexter.tasks.back_process_feeds',
    },
    'fetch_yesterdays_feeds_rerun': {
        'schedule': crontab(hour=14, minute=30),
        'task': 'dexter.tasks.back_process_feeds',
    },
    # 'backfill-taxonomies': {
    #     'schedule': crontab(hour=21, minute=0),
    #     'task': 'dexter.tasks.backfill_taxonomies',
    # },


}

@@ -920,9 +920,9 @@
 ur=1
-4
+6
 , mi
@@ -961,34 +961,44 @@
 r.tasks.
-back_proces
+fetch_yesterday
 s_feeds
+_rerun
 ',%0A    %7D

Add new keyfile