dd

backend/celery_tasks/schedule_loader.py

@@ -64,6 +64,7 @@ def load_schedules_task():
     This task runs every 5 minutes to check for new or updated schedules.
     """
     try:
+        print(f"[CELERY BEAT] Loading schedules from database at {datetime.now()}...")
         logger.info("Loading schedules from database...")
         
         # Get Supabase configuration
@@ -84,6 +85,7 @@ def load_schedules_task():
         )
         
         schedules = response.data if response.data else []
+        print(f"[CELERY BEAT] Found {len(schedules)} schedules in database")
         logger.info(f"Found {len(schedules)} schedules")
         
         # Get current beat schedule
@@ -147,6 +149,7 @@ def load_schedules_task():
         
         # Update the beat schedule
         current_app.conf.beat_schedule = new_schedule
+        print(f"[CELERY BEAT] Successfully updated Celery Beat schedule with {len(new_schedule)} jobs")
         logger.info("Updated Celery Beat schedule")
         
         return {

start_app.py

@@ -51,19 +51,19 @@ def start_celery_components():
     ]
     
     if platform.system() == "Windows":
-        # Windows: Use subprocess to start background processes
+        # Windows: Use subprocess to start background processes with visible logs
         subprocess.Popen(worker_cmd, cwd=backend_dir,
-                        stdout=subprocess.PIPE, stderr=subprocess.PIPE,
+                        stdout=sys.stdout, stderr=sys.stderr,
                         creationflags=subprocess.CREATE_NEW_PROCESS_GROUP)
         subprocess.Popen(beat_cmd, cwd=backend_dir,
-                        stdout=subprocess.PIPE, stderr=subprocess.PIPE,
+                        stdout=sys.stdout, stderr=sys.stderr,
                         creationflags=subprocess.CREATE_NEW_PROCESS_GROUP)
     else:
-        # Linux/Mac: Use subprocess with proper signal handling
+        # Linux/Mac: Use subprocess with visible logs
         subprocess.Popen(worker_cmd, cwd=backend_dir,
-                        stdout=subprocess.PIPE, stderr=subprocess.PIPE)
+                        stdout=sys.stdout, stderr=sys.stderr)
         subprocess.Popen(beat_cmd, cwd=backend_dir,
-                        stdout=subprocess.PIPE, stderr=subprocess.PIPE)
+                        stdout=sys.stdout, stderr=sys.stderr)
     
     print("Celery worker and beat scheduler started in background")
     time.sleep(2)  # Give Celery components time to start