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=3, 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=16, minute=30),
    #     'task': 'dexter.tasks.fetch_yesterdays_feeds_rerun',
    # },
    # 'backfill-taxonomies': {
    #     'schedule': crontab(hour=21, minute=0),
    #     'task': 'dexter.tasks.backfill_taxonomies',
    # },


}

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=11, 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=16, minute=30),
    #     'task': 'dexter.tasks.fetch_yesterdays_feeds_rerun',
    # },
    # 'backfill-taxonomies': {
    #     'schedule': crontab(hour=21, minute=0),
    #     'task': 'dexter.tasks.backfill_taxonomies',
    # },


}

Add remove tasks