Add django celery beat task in celery.py

DEENUU1 · Jan 8, 2024 · cce3548 · cce3548
1 parent f737b80
commit cce3548
Showing 1 changed file with 6 additions and 18 deletions.
diff --git a/fjob/celery.py b/fjob/celery.py
@@ -10,21 +10,9 @@
 app.config_from_object(settings, namespace="CELERY")
 app.autodiscover_tasks()
 
-# app.conf.beat_schedule = {
-#     "delete-scraped-offers-after-30-days": {
-#         "task": "offer.task.delete_scraped_offers_after_30_days",
-#         "schedule": 86400,  # Every 24H
-#     },
-#     "delete-offers-after-year": {
-#         "task": "offer.task.delete_offers_after_year",
-#         "schedule": 86400,  # Every 24H
-#     },
-#     "delete-contact-after-year": {
-#         "task": "support.task.delete_contact_after_year",
-#         "schedule": 86400,  # Every 24H
-#     },
-#     "delete-report-after-year": {
-#         "task": "support.task.delete_report_after_year",
-#         "schedule": 86400,  # Every 24H
-#     }
-# }
+app.conf.beat_schedule = {
+    "update_expired_offer_status": {
+        "task": "offer.tasks.update_expired_offer_status",
+        "schedule": 86400,  # Run every 24h
+    }
+}