File tree Expand file tree Collapse file tree 2 files changed +8
-10
lines changed
safe_transaction_service/history Expand file tree Collapse file tree 2 files changed +8
-10
lines changed Original file line number Diff line number Diff line change @@ -1350,7 +1350,14 @@ def safes_pending_to_be_processed(self) -> QuerySet[ChecksumAddress]:
13501350 :return: List of Safe addresses that have transactions pending to be processed
13511351 """
13521352 # Use denormalized safe_address field (avoids JOIN with internal_tx)
1353- return self .not_processed ().values_list ("safe_address" , flat = True ).distinct ()
1353+ return (
1354+ self .not_processed ()
1355+ .filter (
1356+ safe_address__in = SafeContract .objects .values_list ("address" , flat = True )
1357+ )
1358+ .values_list ("safe_address" , flat = True )
1359+ .distinct ()
1360+ )
13541361
13551362
13561363class InternalTxDecoded (models .Model ):
Original file line number Diff line number Diff line change @@ -230,15 +230,6 @@ def test_process_decoded_internal_txs_task_together(self):
230230 cm .output [0 ],
231231 )
232232
233- def test_process_decoded_internal_txs_task_different_tasks (self ):
234- with self .settings (PROCESSING_ALL_SAFES_TOGETHER = False ):
235- with self .assertLogs (logger = task_logger ) as cm :
236- self ._test_process_decoded_internal_txs_task ()
237- self .assertIn (
238- "Start process decoded internal txs for every Safe in a different task" ,
239- cm .output [0 ],
240- )
241-
242233 def test_process_decoded_internal_txs_for_banned_safe (self ):
243234 owner = Account .create ().address
244235 safe_address = Account .create ().address
You can’t perform that action at this time.
0 commit comments