调整

run.py

@@ -35,13 +35,13 @@ 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()
+    celery_worker_process = start_celery_worker()
+    celery_beat_process = start_celery_beat()
  
     # 等待子进程完成
     fastapi_process.wait()
-    #celery_worker_process.wait()
-    #celery_beat_process.wait()
+    celery_worker_process.wait()
+    celery_beat_process.wait()
 
 
 # def signal_handler(sig, frame):