diff --git a/cli/Cargo.toml b/cli/Cargo.toml index 5a799fd..8da801e 100644 --- a/cli/Cargo.toml +++ b/cli/Cargo.toml @@ -23,7 +23,7 @@ tonic = "0.14.1" tonic-reflection = "0.14.1" prost-types = "0.14.1" prost = "0.14.1" -cortexflow_agent_api = "0.1.1-beta.1" +cortexflow_agent_api = "0.1.1-beta.2" [[bin]] name = "cfcli" diff --git a/core/api/Cargo.toml b/core/api/Cargo.toml index 39ca343..5136245 100644 --- a/core/api/Cargo.toml +++ b/core/api/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "cortexflow_agent_api" -version = "0.1.1-beta.1" +version = "0.1.1-beta.2" edition = "2021" description = "CortexFlow agent API" authors = ["Lorenzo Tettamanti", "Pranav Verma", "Lorenzo Bradanini","Siddharth Sutar","Andrea Bozzo"] diff --git a/core/api/src/api.rs b/core/api/src/api.rs index 29d0e8d..4bb266d 100644 --- a/core/api/src/api.rs +++ b/core/api/src/api.rs @@ -181,13 +181,6 @@ impl Default for AgentApi { } } else if events.read == 0 { info!("[Agent/API] 0 Events found"); - let mut evt = Vec::new(); - evt.push(ConnectionEvent { - event_id: "0".to_string(), - src_ip_port: "0:0".to_string(), - dst_ip_port: "0:0".to_string(), - }); - let _ = tx.send(Ok(evt)).await; } } Err(e) => {