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" diff --git a/crates/base/src/runner.rs b/crates/base/src/runner.rs index 5c2b59b..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; definition_service.send().await; }