diff --git a/packages/discovery-provider/src/app.py b/packages/discovery-provider/src/app.py index 1a40227d35b..4aa1cb11d68 100644 --- 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 index d2a300e403a..40f8d10fa03 100644 --- 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 index 7074364b4c5..a9ad89cd37a 100644 --- 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" + )