diff --git a/dingxin_toolbox_drf/celery.py b/dingxin_toolbox_drf/celery.py index 50ddf56..9415148 100644 --- a/dingxin_toolbox_drf/celery.py +++ b/dingxin_toolbox_drf/celery.py @@ -14,6 +14,10 @@ app.config_from_object('django.conf:settings', namespace='CELERY') # 自动发现并添加任务 app.autodiscover_tasks() +# 强制单实例运行 +app.conf.worker_prefetch_multiplier=1 +app.conf.task_acks_late=True + # app.conf.beat_schedule = { # 'update_client_task': { # 'task': 'update.tasks.update_client',