from __future__ import absolute_import

import os

from celery import Celery
from django.conf import settings

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'conf.settings.production')

app = Celery('promvtor',
             broker='amqp://',
             backend='redis://localhost:6379/0',
             )

app.config_from_object('django.conf:settings')
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)

app.conf.update(
    CELERY_ACCEPT_CONTENT=['json'],
    CELERY_TASK_SERIALIZER='json',
    CELERY_RESULT_SERIALIZER='json',
    CELERY_TIMEZONE='Europe/Moscow',
    CELERY_ENABLE_UTC=True,
)

@app.task(bind=True)
def debug_task(self):
    print('Request: {0!r}'.format(self.request))