@@ -181,6 +181,10 @@ impl<Z: SpawnedSignerTrait> SignerTest<Z> {
181
181
})
182
182
.unwrap();
183
183
let info = get_chain_info(&self.running_nodes.conf);
184
+ info!(
185
+ "Waiting for signers to agree on expected tenure id: {}",
186
+ info.pox_consensus
187
+ );
184
188
let res = wait_for_state_machine_update_by_miner_tenure_id(
185
189
30,
186
190
&info.pox_consensus,
@@ -7250,24 +7254,26 @@ fn empty_sortition_before_approval() {
7250
7254
7251
7255
signer_test.boot_to_epoch_3();
7252
7256
7253
- let skip_commit_op = signer_test
7254
- .running_nodes
7255
- .counters
7256
- .naka_skip_commit_op
7257
- .clone();
7258
- let proposed_blocks = signer_test
7259
- .running_nodes
7260
- .counters
7261
- .naka_proposed_blocks
7262
- .clone();
7257
+ let Counters {
7258
+ naka_submitted_commits: commits_submitted,
7259
+ naka_proposed_blocks: proposed_blocks,
7260
+ naka_skip_commit_op: skip_commit_op,
7261
+ ..
7262
+ } = signer_test.running_nodes.counters.clone();
7263
7263
7264
+ let commits_before = commits_submitted.load(Ordering::SeqCst);
7264
7265
next_block_and_process_new_stacks_block(
7265
7266
&signer_test.running_nodes.btc_regtest_controller,
7266
7267
60,
7267
7268
&signer_test.running_nodes.coord_channel,
7268
7269
)
7269
7270
.unwrap();
7270
7271
7272
+ wait_for(30, || {
7273
+ Ok(commits_submitted.load(Ordering::SeqCst) > commits_before)
7274
+ })
7275
+ .expect("Timed out waiting for commit to be submitted for Tenure A");
7276
+
7271
7277
let info = get_chain_info(&signer_test.running_nodes.conf);
7272
7278
let burn_height_before = info.burn_block_height;
7273
7279
let stacks_height_before = info.stacks_tip_height;
0 commit comments