feat(managed-instance): warn user for unsupported flush strategy configuration

Author: litianningdatadog

bottlecap/src/bin/bottlecap/main.rs

@@ -99,7 +99,7 @@ use std::{collections::hash_map, env, path::Path, str::FromStr, sync::Arc};
 use tokio::time::{Duration, Instant};
 use tokio::{sync::Mutex as TokioMutex, sync::mpsc::Sender, task::JoinHandle};
 use tokio_util::sync::CancellationToken;
-use tracing::{debug, error};
+use tracing::{debug, error, warn};
 use tracing_subscriber::EnvFilter;
 use ustr::Ustr;
 
@@ -443,12 +443,15 @@ fn get_flush_strategy_for_mode(
     if let FlushStrategy::Continuously(_) = configured_strategy {
         configured_strategy
     } else {
-        debug!(
-            "Managed Instance mode detected. Flush strategy '{}' is not compatible with managed instance mode. \
-            Enforcing continuous flush strategy with {}ms interval for optimal performance.",
-            configured_strategy.name(),
-            DEFAULT_CONTINUOUS_FLUSH_INTERVAL
-        );
+        // Only log if the user explicitly configured a non-default strategy
+        if !matches!(configured_strategy, FlushStrategy::Default) {
+            warn!(
+                "Managed Instance mode detected. Flush strategy '{}' is not compatible with managed instance mode. \
+                Enforcing continuous flush strategy with {}ms interval for optimal performance.",
+                configured_strategy.name(),
+                DEFAULT_CONTINUOUS_FLUSH_INTERVAL
+            );
+        }
 
         FlushStrategy::Continuously(PeriodicStrategy {
             interval: DEFAULT_CONTINUOUS_FLUSH_INTERVAL,

bottlecap/src/extension/telemetry/events.rs

@@ -432,12 +432,20 @@ mod tests {
                 spans: Some(vec![
                     TelemetrySpan {
                         name: "responseLatency".to_string(),
-                        start: chrono::Utc.with_ymd_and_hms(2025, 9, 19, 19, 36, 50).unwrap().with_nanosecond(880_000_000).unwrap(),
+                        start: chrono::Utc.with_ymd_and_hms(2025, 9, 19, 19, 36, 50)
+                            .single()
+                            .expect("test date should be valid")
+                            .with_nanosecond(880_000_000)
+                            .expect("test nanosecond should be valid"),
                         duration_ms: 0.847,
                     },
                     TelemetrySpan {
                         name: "responseDuration".to_string(),
-                        start: chrono::Utc.with_ymd_and_hms(2025, 9, 19, 19, 36, 50).unwrap().with_nanosecond(880_000_000).unwrap(),
+                        start: chrono::Utc.with_ymd_and_hms(2025, 9, 19, 19, 36, 50)
+                            .single()
+                            .expect("test date should be valid")
+                            .with_nanosecond(880_000_000)
+                            .expect("test nanosecond should be valid"),
                         duration_ms: 0.127,
                     },
                 ]),

bottlecap/src/secrets/decrypt.rs

@@ -543,6 +543,7 @@ mod tests {
                 sandbox_init_time: Instant::now(),
                 runtime_api: String::new(),
                 exec_wrapper: None,
+                initialization_type: "on-demand".into(),
             }),
             &AwsCredentials{
                 aws_access_key_id: "AKIDEXAMPLE".to_string(),
@@ -602,6 +603,7 @@ mod tests {
                 sandbox_init_time: Instant::now(),
                 runtime_api: String::new(),
                 exec_wrapper: None,
+                initialization_type: "on-demand".into(),
             }),
             &AwsCredentials{
                 aws_access_key_id: "AKIDEXAMPLE".to_string(),

local_tests/managed-instance/Dockerfile

@@ -8,7 +8,8 @@ ARG TARGET=managed-instance
 ENV LOG_LEVEL=debug
 ENV DD_LOG_LEVEL=debug
 # Enforce flushing
-ENV DD_SERVERLESS_FLUSH_STRATEGY=continuously,1000
+# ENV DD_SERVERLESS_FLUSH_STRATEGY=continuously,60000
+# ENV DD_SERVERLESS_FLUSH_STRATEGY=periodically,60000
 
 
 # ---- Add remote dev tooling ----