diff --git a/Cargo.lock b/Cargo.lock index d11c3f2..9e05278 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -259,9 +259,9 @@ dependencies = [ [[package]] name = "code0-flow" -version = "0.0.23" +version = "0.0.24" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "3f5a81df6372bf90457b89c9d45a8a5d9b042ea4478243266d5e54bc3e491369" +checksum = "f4ebec2afaa7c154191715c695390a7552693d0664efff399633150972f1accb" dependencies = [ "async-nats", "async-trait", @@ -2025,9 +2025,9 @@ dependencies = [ [[package]] name = "tucana" -version = "0.0.51" +version = "0.0.52" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "b159f2c4bec2370240c3537f755a69bb3fca6589b6eebfc3240b3b4ace64e8fa" +checksum = "63e1cec14d8140417b330fffd1fb07f52cbd69063a4bd5688e63511b5bf8c8aa" dependencies = [ "pbjson", "pbjson-build", diff --git a/Cargo.toml b/Cargo.toml index ee4e63b..01d49f3 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -10,8 +10,8 @@ log = "0.4.26" env_logger = "0.11.8" prost = "0.14.1" tonic = "0.14.1" -tucana = { version = "0.0.51", features = ["all"] } -code0-flow = { version = "0.0.23", features = ["flow_health", "flow_validator"] } +tucana = { version = "0.0.52", features = ["all"] } +code0-flow = { version = "0.0.24", features = ["flow_health", "flow_validator"] } serde_json = "1.0.140" async-nats = "0.46.0" tonic-health = "0.14.1" diff --git a/src/sagittarius/flow_service_client_impl.rs b/src/sagittarius/flow_service_client_impl.rs index bcbe47a..e1d82ce 100644 --- a/src/sagittarius/flow_service_client_impl.rs +++ b/src/sagittarius/flow_service_client_impl.rs @@ -96,6 +96,7 @@ impl SagittariusFlowClient { for flow in flows.flows { let key = get_flow_identifier(&flow); + log::debug!("trying to insert: {}", key); let bytes = flow.encode_to_vec(); match self.store.put(key, bytes.into()).await { Ok(_) => log::info!("Flow updated successfully"),