From 88ed065e022afb0acc0fc884db77a96ce4becdbd Mon Sep 17 00:00:00 2001
From: Raphael <raphael.goetz.7@gmail.com>
Date: Wed, 15 Apr 2026 21:09:22 +0200
Subject: [PATCH 1/2] dependencies: updated to code0-flow 0.0.31

---
 Cargo.lock | 12 ++++++------
 Cargo.toml |  2 +-
 2 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/Cargo.lock b/Cargo.lock
index 77de6bc..7d9bcb6 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -289,9 +289,9 @@ checksum = "c8d4a3bb8b1e0c1050499d1815f5ab16d04f0959b233085fb31653fbfc9d98f9"
 
 [[package]]
 name = "code0-flow"
-version = "0.0.30"
+version = "0.0.31"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "8401c34395889c3587792864120d2ff4354d24e79db8ffb01c17accc550d0de6"
+checksum = "fa74faab97705675a1288230e0861d8a61a5456a4adc81387c8fc0505c11df5c"
 dependencies = [
  "async-nats",
  "async-trait",
@@ -508,7 +508,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "39cab71617ae0d63f51a36d69f866391735b51691dbda63cf6f96d042b63efeb"
 dependencies = [
  "libc",
- "windows-sys 0.52.0",
+ "windows-sys 0.61.2",
 ]
 
 [[package]]
@@ -1467,7 +1467,7 @@ dependencies = [
  "errno",
  "libc",
  "linux-raw-sys",
- "windows-sys 0.52.0",
+ "windows-sys 0.61.2",
 ]
 
 [[package]]
@@ -1801,7 +1801,7 @@ dependencies = [
  "getrandom 0.4.2",
  "once_cell",
  "rustix",
- "windows-sys 0.52.0",
+ "windows-sys 0.61.2",
 ]
 
 [[package]]
@@ -2367,7 +2367,7 @@ version = "0.1.11"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "c2a7b1c03c876122aa43f3020e6c3c3ee5c05081c9a00739faf7503aeba10d22"
 dependencies = [
- "windows-sys 0.52.0",
+ "windows-sys 0.61.2",
 ]
 
 [[package]]
diff --git a/Cargo.toml b/Cargo.toml
index 45c66a8..cb9f790 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -8,7 +8,7 @@ edition = "2024"
 
 [workspace.dependencies]
 async-trait = "0.1.89"
-code0-flow = { version = "0.0.30" }
+code0-flow = { version = "0.0.31" }
 tucana = { version = "0.0.68" }
 tokio = { version = "1.44.1", features = ["rt-multi-thread", "signal"] }
 log = "0.4.27"

From 7cd0cdc9c492ce6fb9683e2b22a29d093c1910d5 Mon Sep 17 00:00:00 2001
From: Raphael <raphael.goetz.7@gmail.com>
Date: Wed, 15 Apr 2026 21:09:37 +0200
Subject: [PATCH 2/2] feat: added inifnite retry definition update

---
 crates/taurus/src/main.rs | 24 +++++++++++++++++++-----
 1 file changed, 19 insertions(+), 5 deletions(-)

diff --git a/crates/taurus/src/main.rs b/crates/taurus/src/main.rs
index 211cb9f..46893fa 100644
--- a/crates/taurus/src/main.rs
+++ b/crates/taurus/src/main.rs
@@ -14,12 +14,13 @@ use futures_lite::StreamExt;
 use log::error;
 use prost::Message;
 use std::collections::HashMap;
-use std::time::Instant;
+use std::time::{Duration, Instant};
 use taurus_core::context::context::Context;
 use taurus_core::context::executor::Executor;
 use taurus_core::context::registry::FunctionStore;
 use taurus_core::context::signal::Signal;
 use tokio::signal;
+use tokio::time::sleep;
 use tonic_health::pb::health_server::HealthServer;
 use tucana::shared::value::Kind;
 use tucana::shared::{
@@ -111,17 +112,30 @@ async fn main() {
         None
     };
 
-    // Optional: dynamic mode sync at startup
     if config.mode == DYNAMIC {
-        FlowUpdateService::from_url(
+        let definition_service = FlowUpdateService::from_url(
             config.aquila_url.clone(),
             config.definitions.clone().as_str(),
             config.aquila_token.clone(),
         )
-        .await
-        .send()
         .await;
 
+        let mut success = false;
+        let mut count = 1;
+        while !success {
+            success = definition_service.send_with_status().await;
+            if success {
+                break;
+            }
+
+            log::warn!(
+                "Updating definitions failed, trying again in 2 secs (retry number {})",
+                count
+            );
+            count += 1;
+            sleep(Duration::from_secs(3)).await;
+        }
+
         let usage_service = TaurusRuntimeUsageService::from_url(
             config.aquila_url.clone(),
             config.aquila_token.clone(),