Merge pull request #149 from code0-tech/148-grpc-retry

raphael-goetz · web-flow · commit 357f15611176 · 2026-02-02T15:21:38.000+01:00
Retry gRPC Connection to Aquila
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -7,7 +7,7 @@ version = "0.0.0"
 edition = "2024"
 
 [workspace.dependencies]
-code0-flow = { version = "0.0.24" }
+code0-flow = { version = "0.0.25" }
 tucana = { version = "0.0.52", features = ["aquila"] }
 serde_json = { version = "1.0.138" }
 log = "0.4.27"
diff --git a/crates/base/src/runner.rs b/crates/base/src/runner.rs
@@ -58,7 +58,8 @@ impl<C: LoadConfig> ServerRunner<C> {
             let definition_service = FlowUpdateService::from_url(
                 config.aquila_url.clone(),
                 config.definition_path.as_str(),
-            );
+            )
+            .await;
             definition_service.send().await;
         }
 

Original file line number	Diff line number	Diff line change
`@@ -58,7 +58,8 @@ impl<C: LoadConfig> ServerRunner<C> {`
`58`	`58`	`let definition_service = FlowUpdateService::from_url(`
`59`	`59`	`config.aquila_url.clone(),`
`60`	`60`	`config.definition_path.as_str(),`
`61`		`- );`
	`61`	`+ )`
	`62`	`+ .await;`
`62`	`63`	`definition_service.send().await;`
`63`	`64`	`}`
`64`	`65`