updated celery scheduled tasks for checking if session is expired

Naz-iv · Dec 16, 2023 · 5b02845 · 5b02845
1 parent 442901d
commit 5b02845
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 15 deletions.
diff --git a/core/celery.py b/core/celery.py
@@ -26,12 +26,16 @@
 app.config_from_object(settings, namespace="CELERY")
 
 # Celery Beat Settings
-# app.conf.beat_schedule = {
-#     "check-overdue-task": {
-#         "task": "borrowing_service.tasks.check_overdue_task",
-#         "schedule": crontab(minute="*/1"),
-#     }
-# }
+app.conf.beat_schedule = {
+    "check-overdue-task": {
+        "task": "borrowing_service.tasks.check_overdue_task",
+        "schedule": crontab(minute="*/1"),
+    },
+    "check-payment-session-expiry": {
+        "task": "payment_service.tasks.verify_session_status",
+        "schedule": crontab(minute="*/1"),
+    },
+}
 
 # Load task modules from all registered Django apps.
 app.autodiscover_tasks()

diff --git a/core/settings.py b/core/settings.py
@@ -150,19 +150,11 @@
     "ROTATE_REFRESH_TOKENS": False,
 }
 
-CELERY_BROKER_URL=os.environ["RABBIT_URL"]
+CELERY_BROKER_URL = os.environ["RABBIT_URL"]
 
 #CELERY BEAT
 CELERY_BEAT_SCHEDULER = "django_celery_beat.schedulers:DatabaseScheduler"
 
-# Celery schedule for checking is checkout schedule expired
-CELERY_SCHEDULE = {
-    "check-payment-session-expiry": {
-        "task": "payment_service.tasks.verify_session_status",
-        "schedule": 60.0,
-    },
-}
-
 STRIPE_SECRET_KEY = os.environ.get("STRIPE_SECRET_KEY")
 STRIPE_PUBLISHABLE_KEY = os.environ.get("STRIPE_PUBLISHABLE_KEY")