Add process_decoded_internal_txs_task to the processing queue

safe-global · Oct 30, 2024 · 0546bfa · 0546bfa
1 parent 09c6242
commit 0546bfa
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/config/settings/base.py b/config/settings/base.py
@@ -284,6 +284,10 @@
             "safe_transaction_service.history.tasks.process_decoded_internal_txs_for_safe_task",
             {"queue": "processing", "delivery_mode": "transient"},
         ),
+        (
+            "safe_transaction_service.history.tasks.process_decoded_internal_txs_task",
+            {"queue": "processing", "delivery_mode": "transient"},
+        ),
         (
             "safe_transaction_service.history.tasks.*",
             {"queue": "indexing", "delivery_mode": "transient"},

diff --git a/safe_transaction_service/history/tasks.py b/safe_transaction_service/history/tasks.py
@@ -280,6 +280,8 @@ def process_decoded_internal_txs_task(self) -> Optional[int]:
             else:
                 logger.info("%d Safes to process", count)
 
+            return count
+
 
 @app.shared_task(bind=True)
 @task_timeout(timeout_seconds=LOCK_TIMEOUT)