Juan Leal commited on
Commit
c86e6d3
·
1 Parent(s): e5f65c8

Fixes path issue

Browse files
Files changed (2) hide show
  1. celery_app.py +5 -2
  2. start_celery_worker.sh +1 -0
celery_app.py CHANGED
@@ -1,8 +1,11 @@
1
  from celery import Celery
2
-
3
  # Initialize Celery
4
  celery_app = Celery(
5
  'celery_app',
6
  broker='redis://localhost:6379/0', # Update if using a different broker
7
- backend='redis://localhost:6379/0' # Update if using a different backend
 
8
  )
 
 
 
 
1
  from celery import Celery
 
2
  # Initialize Celery
3
  celery_app = Celery(
4
  'celery_app',
5
  broker='redis://localhost:6379/0', # Update if using a different broker
6
+ backend='redis://localhost:6379/0', # Update if using a different backend
7
+ include=['app_api'] # Directly include the 'app_api' module
8
  )
9
+
10
+ # Load task modules from all registered Django app configs.
11
+ celery_app.autodiscover_tasks(['app_api'])
start_celery_worker.sh CHANGED
@@ -1,3 +1,4 @@
1
  # start_celery_worker.sh
2
 
 
3
  celery -A celery_app worker --loglevel=info
 
1
  # start_celery_worker.sh
2
 
3
+ export PYTHONPATH=.
4
  celery -A celery_app worker --loglevel=info