j

backend/start_celery.py

@@ -32,9 +32,15 @@ def check_redis():
 def start_worker():
     """Start Celery worker."""
     print("Starting Celery worker...")
+    # Add project root to PYTHONPATH
+    project_root = backend_dir.parent.resolve()
+    env = os.environ.copy()
+    current_pythonpath = env.get('PYTHONPATH', '')
+    env['PYTHONPATH'] = str(project_root) + os.pathsep + current_pythonpath if current_pythonpath else str(project_root)
+    
     cmd = [
         sys.executable, "-m", "celery",
-        "-A", "celery_config:celery_app", # Changed from 'celery_config'
+        "-A", "celery_config:celery_app",
         "worker",
         "--loglevel=info",
         "--pool=solo",
@@ -42,27 +48,33 @@ def start_worker():
     ]
     
     if platform.system() == "Windows":
-        subprocess.Popen(cmd, cwd=backend_dir)
+        subprocess.Popen(cmd, cwd=backend_dir, env=env)
     else:
-        subprocess.Popen(cmd, cwd=backend_dir)
+        subprocess.Popen(cmd, cwd=backend_dir, env=env)
     
     print("Celery worker started")
 
 def start_beat():
     """Start Celery Beat scheduler."""
     print("Starting Celery Beat scheduler...")
+    # Add project root to PYTHONPATH
+    project_root = backend_dir.parent.resolve()
+    env = os.environ.copy()
+    current_pythonpath = env.get('PYTHONPATH', '')
+    env['PYTHONPATH'] = str(project_root) + os.pathsep + current_pythonpath if current_pythonpath else str(project_root)
+    
     cmd = [
         sys.executable, "-m", "celery",
-        "-A", "celery_config:celery_app", # Changed from 'celery_config'
+        "-A", "celery_config:celery_app",
         "beat",
         "--loglevel=info",
         "--scheduler=django_celery_beat.schedulers:DatabaseScheduler"
     ]
     
     if platform.system() == "Windows":
-        subprocess.Popen(cmd, cwd=backend_dir)
+        subprocess.Popen(cmd, cwd=backend_dir, env=env)
     else:
-        subprocess.Popen(cmd, cwd=backend_dir)
+        subprocess.Popen(cmd, cwd=backend_dir, env=env)
     
     print("Celery Beat scheduler started")
 

start_app.py

@@ -29,12 +29,19 @@ def start_celery_components():
     """Start Celery worker and beat scheduler in background processes."""
     print("Starting Celery components...")
     
-    backend_dir = Path(__file__).parent / "backend"
+    project_root = Path(__file__).parent.resolve() # Get the project root directory
+    backend_dir = project_root / "backend"
     
+    # Prepare the environment with updated PYTHONPATH
+    env = os.environ.copy()
+    # Prepend the project root to PYTHONPATH so 'backend' package can be found
+    current_pythonpath = env.get('PYTHONPATH', '')
+    env['PYTHONPATH'] = str(project_root) + os.pathsep + current_pythonpath if current_pythonpath else str(project_root)
+
     # Start Celery worker
     worker_cmd = [
         sys.executable, "-m", "celery",
-        "-A", "celery_config:celery_app", # Changed from 'celery_config'
+        "-A", "celery_config:celery_app",
         "worker",
         "--loglevel=info",
         "--pool=solo",
@@ -44,7 +51,7 @@ def start_celery_components():
     # Start Celery beat
     beat_cmd = [
         sys.executable, "-m", "celery",
-        "-A", "celery_config:celery_app", # Changed from 'celery_config'
+        "-A", "celery_config:celery_app",
         "beat",
         "--loglevel=info",
         "--scheduler=django_celery_beat.schedulers:DatabaseScheduler"
@@ -52,17 +59,17 @@ def start_celery_components():
     
     if platform.system() == "Windows":
         # Windows: Use subprocess to start background processes with visible logs
-        subprocess.Popen(worker_cmd, cwd=backend_dir,
+        subprocess.Popen(worker_cmd, cwd=backend_dir, env=env, # Pass the modified env
                         stdout=sys.stdout, stderr=sys.stderr,
                         creationflags=subprocess.CREATE_NEW_PROCESS_GROUP)
-        subprocess.Popen(beat_cmd, cwd=backend_dir,
+        subprocess.Popen(beat_cmd, cwd=backend_dir, env=env, # Pass the modified env
                         stdout=sys.stdout, stderr=sys.stderr,
                         creationflags=subprocess.CREATE_NEW_PROCESS_GROUP)
     else:
         # Linux/Mac: Use subprocess with visible logs
-        subprocess.Popen(worker_cmd, cwd=backend_dir,
+        subprocess.Popen(worker_cmd, cwd=backend_dir, env=env, # Pass the modified env
                         stdout=sys.stdout, stderr=sys.stderr)
-        subprocess.Popen(beat_cmd, cwd=backend_dir,
+        subprocess.Popen(beat_cmd, cwd=backend_dir, env=env, # Pass the modified env
                         stdout=sys.stdout, stderr=sys.stderr)
     
     print("Celery worker and beat scheduler started in background")