Skip to content

Commit

Permalink
rm timeout for kurtosis
Browse files Browse the repository at this point in the history
  • Loading branch information
rnbguy committed Nov 20, 2024
1 parent 34eded9 commit 43ef9bd
Showing 1 changed file with 9 additions and 22 deletions.
31 changes: 9 additions & 22 deletions src/tests/network/ethpkg.rs
Original file line number Diff line number Diff line change
Expand Up @@ -149,29 +149,16 @@ impl EthereumNetwork for EthPkgKurtosis {
.into_inner();

// GET OUTPUT LINES WITH TIMEOUT
let result = tokio::time::timeout(tokio::time::Duration::from_secs(120), async {
while let Some(next_message) = run_result.message().await? {
match next_message.run_response_line {
Some(RunResponseLine::InstructionResult(result)) => {
println!("{}", result.serialized_instruction_result);
}
Some(RunResponseLine::RunFinishedEvent(result)) => {
println!("Run finished: {:#?}", result);
break;
}
_ => continue,
while let Some(next_message) = run_result.message().await? {
match next_message.run_response_line {
Some(RunResponseLine::InstructionResult(result)) => {
println!("{}", result.serialized_instruction_result);
}
}
Ok::<(), anyhow::Error>(())
})
.await;

match result {
Ok(Ok(())) => {}
Ok(Err(e)) => return Err(e.into()),
Err(_) => {
println!("Timeout occurred");
return Err("Operation timed out".into());
Some(RunResponseLine::RunFinishedEvent(result)) => {
println!("Run finished: {:#?}", result);
break;
}
_ => continue,
}
}

Expand Down

0 comments on commit 43ef9bd

Please sign in to comment.