l

backend/celery_tasks/content_tasks.py

@@ -22,6 +22,7 @@ def generate_content_task(self, user_id: str, schedule_id: str, supabase_client_
         dict: Result of content generation
     """
     try:
+        print(f"[CONTENT TASK] Starting content generation for schedule {schedule_id}")
         logger.info(f"Starting content generation for schedule {schedule_id}")
         
         # Update task state
@@ -102,6 +103,7 @@ def publish_post_task(self, schedule_id: str, supabase_client_config: dict):
         dict: Result of post publishing
     """
     try:
+        print(f"[PUBLISH TASK] Starting post publishing for schedule {schedule_id}")
         logger.info(f"Starting post publishing for schedule {schedule_id}")
         
         # Update task state

backend/celery_tasks/schedule_loader.py

@@ -28,6 +28,7 @@ def parse_schedule_time(schedule_time):
         dict: Crontab parameters
     """
     try:
+        print(f"[CELERY BEAT] Parsing schedule time: {schedule_time}")
         day_name, time_str = schedule_time.split()
         hour, minute = map(int, time_str.split(':'))
         
@@ -43,12 +44,13 @@ def parse_schedule_time(schedule_time):
         }
         
         day_of_week = day_map.get(day_name, '*')
-        
-        return {
+        result = {
             'minute': minute,
             'hour': hour,
             'day_of_week': day_of_week
         }
+        print(f"[CELERY BEAT] Parsed schedule time result: {result}")
+        return result
     except Exception as e:
         logger.error(f"Error parsing schedule time {schedule_time}: {str(e)}")
         # Default to every minute for error cases
@@ -133,13 +135,21 @@ def load_schedules_task(self):
                 
                 # Create content generation job (5 minutes before publishing)
                 gen_job_id = f"gen_{schedule_id}"
+                task_schedule = crontab(
+                    minute=content_gen_time['minute'],
+                    hour=content_gen_time['hour'],
+                    day_of_week=content_gen_time['day_of_week']
+                )
+                print(f"[CELERY BEAT] Creating content task - ID: {gen_job_id}")
+                print(f"[CELERY BEAT] Content task schedule: minute={content_gen_time['minute']}, hour={content_gen_time['hour']}, day_of_week={content_gen_time['day_of_week']}")
+                print(f"[CELERY BEAT] Content task args: {(
+                    schedule.get('Social_network', {}).get('id_utilisateur'),
+                    schedule_id,
+                    supabase_config
+                )}")
                 new_schedule[gen_job_id] = {
                     'task': 'backend.celery_tasks.content_tasks.generate_content_task',
-                    'schedule': crontab(
-                        minute=content_gen_time['minute'],
-                        hour=content_gen_time['hour'],
-                        day_of_week=content_gen_time['day_of_week']
-                    ),
+                    'schedule': task_schedule,
                     'args': (
                         schedule.get('Social_network', {}).get('id_utilisateur'),
                         schedule_id,
@@ -151,13 +161,20 @@ def load_schedules_task(self):
                 
                 # Create publishing job
                 pub_job_id = f"pub_{schedule_id}"
+                task_schedule = crontab(
+                    minute=publish_time['minute'],
+                    hour=publish_time['hour'],
+                    day_of_week=publish_time['day_of_week']
+                )
+                print(f"[CELERY BEAT] Creating publish task - ID: {pub_job_id}")
+                print(f"[CELERY BEAT] Publish task schedule: minute={publish_time['minute']}, hour={publish_time['hour']}, day_of_week={publish_time['day_of_week']}")
+                print(f"[CELERY BEAT] Publish task args: {(
+                    schedule_id,
+                    supabase_config
+                )}")
                 new_schedule[pub_job_id] = {
                     'task': 'backend.celery_tasks.content_tasks.publish_post_task',
-                    'schedule': crontab(
-                        minute=publish_time['minute'],
-                        hour=publish_time['hour'],
-                        day_of_week=publish_time['day_of_week']
-                    ),
+                    'schedule': task_schedule,
                     'args': (
                         schedule_id,
                         supabase_config
@@ -170,6 +187,8 @@ def load_schedules_task(self):
                 logger.error(f"Error creating jobs for schedule {schedule.get('id')}: {str(e)}")
         
         # Update the beat schedule
+        print(f"[CELERY BEAT] Current schedule keys before update: {list(current_app.conf.beat_schedule.keys())}")
+        print(f"[CELERY BEAT] New schedule keys: {list(new_schedule.keys())}")
         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")