hj
Browse files- backend/celery_config.py +2 -2
- backend/requirements.txt +0 -1
- backend/start_celery.py +2 -2
- start_app.py +2 -2
backend/celery_config.py
CHANGED
|
@@ -36,8 +36,8 @@ celery_app.conf.update(
|
|
| 36 |
task_acks_late=True,
|
| 37 |
worker_max_tasks_per_child=100,
|
| 38 |
|
| 39 |
-
# Beat scheduler
|
| 40 |
-
beat_scheduler
|
| 41 |
beat_schedule={
|
| 42 |
# This task will run every 5 minutes to load schedules from the database
|
| 43 |
'load-schedules': {
|
|
|
|
| 36 |
task_acks_late=True,
|
| 37 |
worker_max_tasks_per_child=100,
|
| 38 |
|
| 39 |
+
# Beat schedule configuration (scheduler itself will be default)
|
| 40 |
+
# beat_scheduler is not set, so it defaults to 'celery.beat:PersistentScheduler'
|
| 41 |
beat_schedule={
|
| 42 |
# This task will run every 5 minutes to load schedules from the database
|
| 43 |
'load-schedules': {
|
backend/requirements.txt
CHANGED
|
@@ -30,7 +30,6 @@ bcrypt>=4.3.0
|
|
| 30 |
# Task queue
|
| 31 |
celery>=5.5.3
|
| 32 |
redis>=6.4.0
|
| 33 |
-
django-celery-beat>=2.8.1 # Added for database-backed Celery schedules
|
| 34 |
|
| 35 |
# Testing
|
| 36 |
pytest>=8.4.1
|
|
|
|
| 30 |
# Task queue
|
| 31 |
celery>=5.5.3
|
| 32 |
redis>=6.4.0
|
|
|
|
| 33 |
|
| 34 |
# Testing
|
| 35 |
pytest>=8.4.1
|
backend/start_celery.py
CHANGED
|
@@ -67,8 +67,8 @@ def start_beat():
|
|
| 67 |
sys.executable, "-m", "celery",
|
| 68 |
"-A", "celery_config:celery_app",
|
| 69 |
"beat",
|
| 70 |
-
"--loglevel=info"
|
| 71 |
-
|
| 72 |
]
|
| 73 |
|
| 74 |
if platform.system() == "Windows":
|
|
|
|
| 67 |
sys.executable, "-m", "celery",
|
| 68 |
"-A", "celery_config:celery_app",
|
| 69 |
"beat",
|
| 70 |
+
"--loglevel=info"
|
| 71 |
+
# Removed --scheduler argument. Will use default PersistentScheduler.
|
| 72 |
]
|
| 73 |
|
| 74 |
if platform.system() == "Windows":
|
start_app.py
CHANGED
|
@@ -53,8 +53,8 @@ def start_celery_components():
|
|
| 53 |
sys.executable, "-m", "celery",
|
| 54 |
"-A", "celery_config:celery_app",
|
| 55 |
"beat",
|
| 56 |
-
"--loglevel=info"
|
| 57 |
-
|
| 58 |
]
|
| 59 |
|
| 60 |
if platform.system() == "Windows":
|
|
|
|
| 53 |
sys.executable, "-m", "celery",
|
| 54 |
"-A", "celery_config:celery_app",
|
| 55 |
"beat",
|
| 56 |
+
"--loglevel=info"
|
| 57 |
+
# Removed --scheduler argument. Will use default PersistentScheduler.
|
| 58 |
]
|
| 59 |
|
| 60 |
if platform.system() == "Windows":
|