From 024032c80b04a61cf04f2a393395583ef2f0ec25 Mon Sep 17 00:00:00 2001 From: Raphael Date: Mon, 2 Feb 2026 15:14:46 +0100 Subject: [PATCH 1/3] feat: added async aquila client creation --- crates/base/src/runner.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/crates/base/src/runner.rs b/crates/base/src/runner.rs index 5c2b59b..7aeb6cb 100644 --- a/crates/base/src/runner.rs +++ b/crates/base/src/runner.rs @@ -58,7 +58,7 @@ impl ServerRunner { let definition_service = FlowUpdateService::from_url( config.aquila_url.clone(), config.definition_path.as_str(), - ); + ).await; definition_service.send().await; } From d3bced58df03603bea8f55ab8ed4e8941bea534f Mon Sep 17 00:00:00 2001 From: Raphael Date: Mon, 2 Feb 2026 15:14:59 +0100 Subject: [PATCH 2/3] dependencies: updated code0-flow to 0.0.25 --- Cargo.lock | 5 +++-- Cargo.toml | 2 +- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/Cargo.lock b/Cargo.lock index 41ca6a7..f2fdfc5 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -272,9 +272,9 @@ dependencies = [ [[package]] name = "code0-flow" -version = "0.0.24" +version = "0.0.25" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "f4ebec2afaa7c154191715c695390a7552693d0664efff399633150972f1accb" +checksum = "53e10d39ec0c673c18749c0ff66c033806b68d1a99ec49cf1f4657fcd7c9d4b5" dependencies = [ "async-nats", "async-trait", @@ -284,6 +284,7 @@ dependencies = [ "regex", "serde", "serde_json", + "tokio", "tonic", "tonic-health", "tucana", diff --git a/Cargo.toml b/Cargo.toml index a7aabd6..f8079cb 100644 --- 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" From 88ccf5c9e63ee32a90eca8c0d177ed73bcff5cb7 Mon Sep 17 00:00:00 2001 From: Raphael Date: Mon, 2 Feb 2026 15:17:17 +0100 Subject: [PATCH 3/3] ref: cargo fmt --- crates/base/src/runner.rs | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/crates/base/src/runner.rs b/crates/base/src/runner.rs index 7aeb6cb..dc6c67e 100644 --- a/crates/base/src/runner.rs +++ b/crates/base/src/runner.rs @@ -58,7 +58,8 @@ impl ServerRunner { let definition_service = FlowUpdateService::from_url( config.aquila_url.clone(), config.definition_path.as_str(), - ).await; + ) + .await; definition_service.send().await; }