__init__.py
310 Bytes
import os
from celery import Celery
from settings import conf
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'settings')
broker = conf.CELERY_BROKER_URL
app = Celery('celery_compare', broker=broker, include=['celery_compare.tasks'])
app.conf.update(worker_max_tasks_per_child=5, timezone='Asia/Shanghai')