diff --git a/config/settings/base.py b/config/settings/base.py
index 5e17ab994..0aba0bbe1 100644
--- 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
index 7a952dd6b..001c33212 100644
--- 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)