@@ -641,9 +641,6 @@ def _process_safe_creation_events(
641641 - SafeSetup
642642 - ProxyCreation
643643
644- Note: When conditional indexing is enabled, events are filtered by tx._from
645- in process_elements() before this method is called.
646-
647644 :param safe_addresses_with_creation_events:
648645 :return: Generated InternalTxs for safe creation
649646 """
@@ -747,10 +744,9 @@ def _process_safe_creation_events(
747744
748745 logger .debug ("InternalTx and InternalTxDecoded objects for creation were built" )
749746
750- stored_internal_txs = InternalTx .objects .store_internal_txs_and_decoded_in_db (
747+ return InternalTx .objects .store_internal_txs_and_decoded_in_db (
751748 internal_txs , internal_txs_decoded
752749 )
753- return stored_internal_txs
754750
755751 def _prefetch_timestamp_for_blocks (
756752 self , decoded_elements : list [EventData ]
@@ -880,20 +876,23 @@ def _process_decoded_elements(
880876 )
881877 processed_elements .extend (creation_events_processed )
882878
883- # When conditional indexing is enabled, filter non-creation events
884- # to only process events for Safes that exist in SafeContract table
885- elements_to_process = decoded_elements
879+ elements_to_process = [
880+ element
881+ for element in decoded_elements
882+ if element ["event" ] not in ("SafeSetup" , "ProxyCreation" )
883+ ]
884+
885+ # When conditional indexing is enabled, only process events for Safes
886+ # that exist in SafeContract table
886887 if self .conditional_indexing_enabled :
887888 # Get all unique Safe addresses from non-creation events
888889 non_creation_addresses = {
889- element ["address" ]
890- for element in decoded_elements
891- if element ["event" ] not in ("SafeSetup" , "ProxyCreation" )
890+ element ["address" ] for element in decoded_elements
892891 }
893892 if non_creation_addresses :
894893 # Check which addresses exist in SafeContract
895894 existing_addresses = SafeContract .objects .get_existing_addresses (
896- list ( non_creation_addresses )
895+ non_creation_addresses
897896 )
898897 skipped_count = len (non_creation_addresses ) - len (existing_addresses )
899898 if skipped_count :
@@ -907,8 +906,7 @@ def _process_decoded_elements(
907906 elements_to_process = [
908907 element
909908 for element in decoded_elements
910- if element ["event" ] in ("SafeSetup" , "ProxyCreation" )
911- or element ["address" ] in existing_addresses
909+ if element ["address" ] in existing_addresses
912910 ]
913911
914912 # Store everything together in the database if possible
0 commit comments