@@ -313,9 +313,9 @@ def test_sync_from_assumeutxo_node(self, snapshot):
313
313
self .sync_blocks (nodes = (miner , snapshot_node ))
314
314
# Check the base snapshot block was stored and ensure node signals full-node service support
315
315
self .wait_until (lambda : not try_rpc (- 1 , "Block not found" , snapshot_node .getblock , snapshot_block_hash ))
316
- assert 'NETWORK' in snapshot_node .getnetworkinfo ()['localservicesnames' ]
316
+ self . wait_until ( lambda : 'NETWORK' in snapshot_node .getnetworkinfo ()['localservicesnames' ])
317
317
318
- # Now the snapshot_node is sync , verify the ibd_node can sync from it
318
+ # Now that the snapshot_node is synced , verify the ibd_node can sync from it
319
319
self .connect_nodes (snapshot_node .index , ibd_node .index )
320
320
assert 'NETWORK' in ibd_node .getpeerinfo ()[0 ]['servicesnames' ]
321
321
self .sync_blocks (nodes = (ibd_node , snapshot_node ))
@@ -660,7 +660,7 @@ def check_tx_counts(final: bool) -> None:
660
660
self .wait_until (lambda : len (n2 .getchainstates ()['chainstates' ]) == 1 )
661
661
662
662
# Once background chain sync completes, the full node must start offering historical blocks again.
663
- assert {'NETWORK' , 'NETWORK_LIMITED' }.issubset (n2 .getnetworkinfo ()['localservicesnames' ])
663
+ self . wait_until ( lambda : {'NETWORK' , 'NETWORK_LIMITED' }.issubset (n2 .getnetworkinfo ()['localservicesnames' ]) )
664
664
665
665
completed_idx_state = {
666
666
'basic block filter index' : COMPLETE_IDX ,
0 commit comments