@@ -314,9 +314,9 @@ def test_sync_from_assumeutxo_node(self, snapshot):
314314 self .sync_blocks (nodes = (miner , snapshot_node ))
315315 # Check the base snapshot block was stored and ensure node signals full-node service support
316316 self .wait_until (lambda : not try_rpc (- 1 , "Block not found" , snapshot_node .getblock , snapshot_block_hash ))
317- assert 'NETWORK' in snapshot_node .getnetworkinfo ()['localservicesnames' ]
317+ self . wait_until ( lambda : 'NETWORK' in snapshot_node .getnetworkinfo ()['localservicesnames' ])
318318
319- # Now the snapshot_node is sync , verify the ibd_node can sync from it
319+ # Now that the snapshot_node is synced , verify the ibd_node can sync from it
320320 self .connect_nodes (snapshot_node .index , ibd_node .index )
321321 assert 'NETWORK' in ibd_node .getpeerinfo ()[0 ]['servicesnames' ]
322322 self .sync_blocks (nodes = (ibd_node , snapshot_node ))
@@ -698,7 +698,7 @@ def check_tx_counts(final: bool) -> None:
698698 self .wait_until (lambda : len (n2 .getchainstates ()['chainstates' ]) == 1 )
699699
700700 # Once background chain sync completes, the full node must start offering historical blocks again.
701- assert {'NETWORK' , 'NETWORK_LIMITED' }.issubset (n2 .getnetworkinfo ()['localservicesnames' ])
701+ self . wait_until ( lambda : {'NETWORK' , 'NETWORK_LIMITED' }.issubset (n2 .getnetworkinfo ()['localservicesnames' ]) )
702702
703703 completed_idx_state = {
704704 'basic block filter index' : COMPLETE_IDX ,
0 commit comments