18 lines
519 B
Python
18 lines
519 B
Python
# core/celery_app.py
|
|
from celery import Celery
|
|
from core.config import settings # Import your settings
|
|
|
|
celery_app = Celery(
|
|
"worker",
|
|
broker=settings.REDIS_URL,
|
|
backend=settings.REDIS_URL,
|
|
include=[
|
|
"modules.auth.tasks",
|
|
"modules.admin.tasks",
|
|
], # Add paths to modules containing tasks
|
|
# Add other modules with tasks here, e.g., "modules.some_other_module.tasks"
|
|
)
|
|
|
|
# Optional: Update Celery configuration directly if needed
|
|
# celery_app.conf.update(task_track_started=True)
|