diff --git a/app/celery_app.py b/app/celery_app.py index 3107ce8..40503c4 100644 --- a/app/celery_app.py +++ b/app/celery_app.py @@ -30,14 +30,15 @@ celery_app.conf.update( worker_max_tasks_per_child=1000, # Beat 调度配置 + # crontab(hour=9, minute=0) # 每天上午9点执行 beat_schedule={ 'push-data-to-dtc-every-minute': { 'task': 'push_data_to_dtc', - 'schedule': 120.0, # 每120秒执行一次(1分钟) + 'schedule': 120.0, # 每120秒执行一次(2分钟) }, 'daily-morning-task': { 'task': 'call_api', - 'schedule': crontab(hour=9, minute=0) # 每天上午9点执行 + 'schedule': 120.0, # 每120秒执行一次(2分钟) }, }, )