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'])

# worker_max_tasks_per_child ,worker执行了几次任务就会死
#app.conf.update(worker_max_tasks_per_child=10, timezone='Asia/Shanghai')
app.conf.update(timezone='Asia/Shanghai')