Skip to content

Commit fc46117

Browse files
Update from github-actions[bot] running command 'fmt'
1 parent b076543 commit fc46117

File tree

1 file changed

+4
-4
lines changed
  • cumulus/zombienet/zombienet-sdk/tests/zombie_ci/statement_store

1 file changed

+4
-4
lines changed

cumulus/zombienet/zombienet-sdk/tests/zombie_ci/statement_store/integration.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -471,10 +471,10 @@ async fn statement_store_peer_disconnect_during_major_sync() -> Result<(), anyho
471471
let sync_end = dave_join_time.elapsed();
472472
info!("Dave reached block height {:.0} after {:.1}s", charlie_height, sync_end.as_secs_f64());
473473

474-
// Subscribe after sync — any statements arriving are exclusively due to reconnect_statement_peers
475-
// triggering a fresh initial sync from charlie. The subscription also returns statements already
476-
// in dave's store as an initial batch, so we capture all recovered statements regardless of
477-
// whether they arrive before or after the subscribe call
474+
// Subscribe after sync — any statements arriving are exclusively due to
475+
// reconnect_statement_peers triggering a fresh initial sync from charlie. The subscription
476+
// also returns statements already in dave's store as an initial batch, so we capture all
477+
// recovered statements regardless of whether they arrive before or after the subscribe call
478478
let mut subscription = subscribe_topic(&dave_rpc, topic).await?;
479479
let received = expect_statements_unordered(&mut subscription, STATEMENT_COUNT, 30).await?;
480480
let mut received_bytes: Vec<Vec<u8>> = received.into_iter().map(|b| b.to_vec()).collect();

0 commit comments

Comments
 (0)