Only set processed the not processed InternalTxDecoded

- Previously all were updated
safe-global · Sep 26, 2024 · fc8e7e6 · fc8e7e6
1 parent 0e3e9be
commit fc8e7e6
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/safe_transaction_service/__init__.py b/safe_transaction_service/__init__.py
@@ -1,4 +1,4 @@
-__version__ = "5.9.0"
+__version__ = "5.9.1"
 __version_info__ = tuple(
     int(num) if num.isdigit() else num
     for num in __version__.replace("-", ".", 1).split(".")

diff --git a/safe_transaction_service/history/tasks.py b/safe_transaction_service/history/tasks.py
@@ -254,9 +254,9 @@ def process_decoded_internal_txs_task(self) -> Optional[int]:
                     # Mark traces as processed so they are not reprocessed all the time
                     # If not, `InternalTxDecoded` index with `decoded=True` can grow to
                     # a point were `safes_pending_to_be_processed` takes minutes to complete
-                    InternalTxDecoded.objects.for_safe(safe_to_process).update(
-                        processed=True
-                    )
+                    InternalTxDecoded.objects.for_safe(
+                        safe_to_process
+                    ).not_processed().update(processed=True)
                 else:
                     count += 1
                     process_decoded_internal_txs_for_safe_task.delay(