[ONC-52] Self-re-enqueue user_bank and payment_router indexing tasks (#…

…7842)
AudiusProject · Mar 15, 2024 · 77078ae · 77078ae
1 parent b702fe5
commit 77078ae
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 8 deletions.
diff --git a/packages/discovery-provider/src/app.py b/packages/discovery-provider/src/app.py
@@ -367,14 +367,6 @@ def configure_celery(celery, test_config=None):
                 "task": "index_solana_plays",
                 "schedule": timedelta(seconds=5),
             },
-            "index_user_bank": {
-                "task": "index_user_bank",
-                "schedule": timedelta(seconds=1),
-            },
-            "index_payment_router": {
-                "task": "index_payment_router",
-                "schedule": timedelta(seconds=1),
-            },
             "index_challenges": {
                 "task": "index_challenges",
                 "schedule": timedelta(seconds=5),
@@ -543,3 +535,5 @@ def __init__(self, *args, **kwargs):
     # Start tasks that should fire upon startup
     celery.send_task("cache_entity_counts")
     celery.send_task("index_nethermind", queue="index_nethermind")
+    celery.send_task("index_user_bank", queue="index_nethermind")
+    celery.send_task("index_payment_router", queue="index_nethermind")
diff --git a/packages/discovery-provider/src/tasks/index_payment_router.py b/packages/discovery-provider/src/tasks/index_payment_router.py
@@ -988,3 +988,6 @@ def index_payment_router(self):
     finally:
         if have_lock:
             update_lock.release()
+        celery.send_task(
+                "index_payment_router", countdown=0.5, queue="index_nethermind"
+            )
diff --git a/packages/discovery-provider/src/tasks/index_user_bank.py b/packages/discovery-provider/src/tasks/index_user_bank.py
@@ -1119,3 +1119,6 @@ def index_user_bank(self):
     finally:
         if have_lock:
             update_lock.release()
+        celery.send_task(
+                "index_user_bank", countdown=0.5, queue="index_nethermind"
+            )