Merge pull request #531 from biocore/csymons_celery_20230829

Celery Adjustments for Setting Overhaul Live

Author: cassidysymons

microsetta_private_api/celery_utils.py

@@ -37,18 +37,18 @@ def __call__(self, *args, **kwargs):
            "task": "microsetta_private_api.admin.daklapack_polling.poll_dak_orders",  # noqa
            "schedule":  60 * 60 * 4  # every 4 hours
         },
-        # "update_qiita_metadata": {
-        #    "task": "microsetta_private_api.tasks.update_qiita_metadata",  # noqa
-        #    "schedule":  60 * 60 * 24  # every 24 hours
-        # },
+        "update_qiita_metadata": {
+           "task": "microsetta_private_api.tasks.update_qiita_metadata",  # noqa
+           "schedule":  60 * 60 * 24  # every 24 hours
+        },
         "pull_fundrazr_transactions": {
            "task": "microsetta_private_api.util.fundrazr.get_fundrazr_transactions",  # noqa
            "schedule": 60 * 60  # every hour
         },
-        "fulfill_new_transactions": {
-           "task": "microsetta_private_api.util.perk_fulfillment.fulfill_new_transactions",  # noqa
-           "schedule": 60 * 60  # every hour
-        },
+        # "fulfill_new_transactions": {
+        #    "task": "microsetta_private_api.util.perk_fulfillment.fulfill_new_transactions",  # noqa
+        #    "schedule": 60 * 60  # every hour
+        # },
         # "fulfill_subscriptions": {
         #    "task": "microsetta_private_api.util.perk_fulfillment.process_subscription_fulfillments",  # noqa
         #    "schedule": 60 * 60 * 24  # every 24 hours
@@ -57,10 +57,10 @@ def __call__(self, *args, **kwargs):
            "task": "microsetta_private_api.util.perk_fulfillment.check_shipping_updates",  # noqa
            "schedule": 60 * 60 * 4  # every 4 hours
         },
-        # "perks_without_fulfillment_details": {
-        #    "task": "microsetta_private_api.util.perk_fulfillment.perks_without_fulfillment_details",  # noqa
-        #    "schedule": 60 * 60 * 24  # every 24 hours
-        # },
+        "perks_without_fulfillment_details": {
+           "task": "microsetta_private_api.util.perk_fulfillment.perks_without_fulfillment_details",  # noqa
+           "schedule": 60 * 60 * 24  # every 24 hours
+        },
         # "fetch_ffqs": {
         #     "task": "microsetta_private_api.util.vioscreen.fetch_ffqs",
         #     "schedule":  60 * 60 * 24  # every 24 hours

microsetta_private_api/celery_worker.py

@@ -4,15 +4,12 @@
 from microsetta_private_api.admin.daklapack_polling import poll_dak_orders
 from microsetta_private_api.util.fundrazr import get_fundrazr_transactions
 from microsetta_private_api.util.perk_fulfillment import check_shipping_updates
-# from microsetta_private_api.tasks import update_qiita_metadata
+from microsetta_private_api.tasks import update_qiita_metadata
 init_celery(celery, app.app)
 
 # Run any celery tasks that require initialization on worker start
 refresh_headers.delay()  # Initialize the vioscreen task with a token
 poll_dak_orders.delay()  # check for orders
 get_fundrazr_transactions.delay()  # check for new transactions
 check_shipping_updates.delay()  # check for tracking updates
-# update_qiita_metadata.delay()  # run Qiita metadata push
-
-# Disabling Qiita metadata push until we have survey changes in place and
-# are ready to test. - Cassidy 2022-12-01
+update_qiita_metadata.delay()  # run Qiita metadata push