diff --git a/celery_app.py b/celery_app.py index 02325fa..7cdc343 100644 --- a/celery_app.py +++ b/celery_app.py @@ -70,7 +70,7 @@ celery_app.conf.update( beat_scheduler="redbeat.RedBeatScheduler", # 使用 RedBeat 作为调度器 redbeat_redis_url=f"redis://:telpo%231234@{redis_host}:{redis_port}/{redis_db}" # redbeat 存储任务调度信息的 Redis , - redbeat_lock_timeout=10, # 避免多个 Beat 实例冲突 + redbeat_lock_timeout=60, # 避免多个 Beat 实例冲突 beat_max_loop_interval=5 # 让 Celery Beat 每 5 秒检查一次任务 ) diff --git a/run.py b/run.py index 0fdb27f..fe50869 100644 --- a/run.py +++ b/run.py @@ -26,11 +26,11 @@ def start_celery_beat(): if __name__ == "__main__": # 启动 FastAPI、Celery Worker 和 Celery Beat - fastapi_process = start_fastapi() - #celery_worker_process = start_celery_worker() - #celery_beat_process = start_celery_beat() + #fastapi_process = start_fastapi() + celery_worker_process = start_celery_worker() + celery_beat_process = start_celery_beat() # 等待子进程完成 - fastapi_process.wait() - #celery_worker_process.wait() - #celery_beat_process.wait() + #fastapi_process.wait() + celery_worker_process.wait() + celery_beat_process.wait()