diff --git a/Cargo.lock b/Cargo.lock
index 8dd57fd..7c8b356 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -271,9 +271,9 @@ dependencies = [
 
 [[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",
@@ -2416,7 +2416,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 b033015..3849f28 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -7,7 +7,7 @@ version = "0.0.0"
 edition = "2024"
 
 [workspace.dependencies]
-code0-flow = { version = "0.0.31" }
+code0-flow = { version = "0.0.32" }
 tucana = { version = "0.0.68", 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 010403e..52eaf3d 100644
--- a/crates/base/src/runner.rs
+++ b/crates/base/src/runner.rs
@@ -63,7 +63,6 @@ impl<C: LoadConfig> ServerRunner<C> {
     ) -> anyhow::Result<()> {
         let config = self.context.adapter_config.clone();
         let mut runtime_status_service: Option<DracoRuntimeStatusService> = None;
-
         log::info!("Starting Draco Variant: {}", config.draco_variant);
 
         if !config.is_static() {
@@ -85,12 +84,14 @@ impl<C: LoadConfig> ServerRunner<C> {
                 .await;
             };
 
-            let definition_service = FlowUpdateService::from_url(
+            let service_name = format!("draco-{}", config.draco_variant.to_lowercase());
+            let mut definition_service = FlowUpdateService::from_url(
                 config.aquila_url.clone(),
                 config.definition_path.as_str(),
                 config.aquila_token.clone(),
             )
-            .await;
+            .await
+            .with_definition_source(service_name);
 
             let mut success = false;
             let mut count = 1;