diff --git a/Cargo.lock b/Cargo.lock
index ce0a0ae..a7b34d5 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -289,9 +289,9 @@ checksum = "c8d4a3bb8b1e0c1050499d1815f5ab16d04f0959b233085fb31653fbfc9d98f9"
 
 [[package]]
 name = "code0-flow"
-version = "0.0.31"
+version = "0.0.32"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "fa74faab97705675a1288230e0861d8a61a5456a4adc81387c8fc0505c11df5c"
+checksum = "bb7d74d62174eb76c90d7c1642a05f20084bb563ec8a1249c0f05bbd7ed03023"
 dependencies = [
  "async-nats",
  "async-trait",
diff --git a/Cargo.toml b/Cargo.toml
index 3f53c22..535ef28 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.31" }
+code0-flow = { version = "0.0.32" }
 tucana = { version = "0.0.68" }
 tokio = { version = "1.44.1", features = ["rt-multi-thread", "signal"] }
 log = "0.4.27"
diff --git a/crates/taurus/src/app/mod.rs b/crates/taurus/src/app/mod.rs
index 0da58ca..3bf3587 100644
--- a/crates/taurus/src/app/mod.rs
+++ b/crates/taurus/src/app/mod.rs
@@ -129,12 +129,13 @@ async fn setup_dynamic_services_if_needed(
 }
 
 async fn push_definitions_until_success(config: &Config) {
-    let definition_service = FlowUpdateService::from_url(
+    let mut definition_service = FlowUpdateService::from_url(
         config.aquila_url.clone(),
         config.definitions.as_str(),
         config.aquila_token.clone(),
     )
-    .await;
+    .await
+    .with_definition_source(String::from("taurus"));
 
     let mut retry_count = 1;
     loop {