From a225ea95ad0705504e002170d013f629353e1d03 Mon Sep 17 00:00:00 2001 From: Robert Debug Date: Fri, 13 Nov 2020 18:39:00 +0100 Subject: [PATCH] fix old round params --- rust/e2e/src/bin/test_case_1.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/rust/e2e/src/bin/test_case_1.rs b/rust/e2e/src/bin/test_case_1.rs index 4f3f1b8fa..6aaf15184 100644 --- a/rust/e2e/src/bin/test_case_1.rs +++ b/rust/e2e/src/bin/test_case_1.rs @@ -43,7 +43,8 @@ async fn run(mut env: TestEnvironment) -> anyhow::Result<()> { info!("wait until clients are ready"); let _ = tokio::join!( utils::wait_until_coordinator_is_ready(&mut api_client), - utils::wait_until_influxdb_is_ready(&influx_client) + utils::wait_until_influxdb_is_ready(&influx_client), + utils::wait_until_phase(&influx_client, PhaseName::Sum) ); //////////////////////////////////////////////////////////////////////////////////////////////// @@ -60,7 +61,6 @@ async fn run(mut env: TestEnvironment) -> anyhow::Result<()> { info!("Round: {}", round); let mut runner = test_client_builder.build_clients().await?; - utils::wait_until_phase(&influx_client, PhaseName::Sum).await; info!("run sum clients..."); runner.run_sum_clients().await?; utils::wait_until_phase(&influx_client, PhaseName::Update).await;