tf

backend/celery_config.py

@@ -6,7 +6,7 @@ This centralizes all Celery configuration to avoid conflicts.
 import os
 from celery import Celery
 from celery.schedules import crontab
-from config import Config # Changed from 'from backend.config import Config'
+from backend.config import Config
 
 # Create Celery instance
 celery_app = Celery('lin_app')
@@ -70,6 +70,6 @@ celery_app.conf.update(
 )
 
 # Import tasks to ensure they're registered
-from . import celery_tasks # Changed from 'from backend import celery_tasks'
+from backend import celery_tasks
 
 __all__ = ['celery_app']

backend/start_celery.py

@@ -34,7 +34,7 @@ def start_worker():
     print("Starting Celery worker...")
     cmd = [
         sys.executable, "-m", "celery",
-        "-A", "celery_config",
+        "-A", "celery_config:celery_app", # Changed from 'celery_config'
         "worker",
         "--loglevel=info",
         "--pool=solo",
@@ -53,7 +53,7 @@ def start_beat():
     print("Starting Celery Beat scheduler...")
     cmd = [
         sys.executable, "-m", "celery",
-        "-A", "celery_config",
+        "-A", "celery_config:celery_app", # Changed from 'celery_config'
         "beat",
         "--loglevel=info",
         "--scheduler=django_celery_beat.schedulers:DatabaseScheduler"

start_app.py

@@ -34,7 +34,7 @@ def start_celery_components():
     # Start Celery worker
     worker_cmd = [
         sys.executable, "-m", "celery",
-        "-A", "celery_config",
+        "-A", "celery_config:celery_app", # Changed from 'celery_config'
         "worker",
         "--loglevel=info",
         "--pool=solo",
@@ -44,7 +44,7 @@ def start_celery_components():
     # Start Celery beat
     beat_cmd = [
         sys.executable, "-m", "celery",
-        "-A", "celery_config",
+        "-A", "celery_config:celery_app", # Changed from 'celery_config'
         "beat",
         "--loglevel=info",
         "--scheduler=django_celery_beat.schedulers:DatabaseScheduler"