style: apply cargo fmt

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

Author: platinummonkey

src/commands/cicd.rs

@@ -47,10 +47,7 @@ pub async fn pipelines_list(
         query_parts.push(format!("@git.branch:\"{}\"", b.replace('"', "\\\"")));
     }
     if let Some(p) = pipeline_name {
-        query_parts.push(format!(
-            "@ci.pipeline.name:\"{}\"",
-            p.replace('"', "\\\"")
-        ));
+        query_parts.push(format!("@ci.pipeline.name:\"{}\"", p.replace('"', "\\\"")));
     }
 
     let mut filter = CIAppPipelinesQueryFilter::new().from(from_str).to(to_str);
@@ -387,9 +384,15 @@ mod tests {
     #[tokio::test]
     async fn test_cicd_events_search_invalid_sort() {
         let cfg = test_config("http://unused.local");
-        let result =
-            super::events_search(&cfg, "*".into(), "1h".into(), "now".into(), 10, "bogus".into())
-                .await;
+        let result = super::events_search(
+            &cfg,
+            "*".into(),
+            "1h".into(),
+            "now".into(),
+            10,
+            "bogus".into(),
+        )
+        .await;
         assert!(result.is_err());
         assert!(result
             .unwrap_err()

src/commands/on_call.rs

@@ -58,9 +58,9 @@ pub(crate) async fn resolve_team_id(cfg: &Config, input: &str) -> Result<String>
         .await
         .map_err(|e| anyhow::anyhow!("failed to resolve team handle '{input}': {e:?}"))?;
 
-    let teams = resp
-        .data
-        .ok_or_else(|| anyhow::anyhow!("unexpected response from teams API: 'data' field missing"))?;
+    let teams = resp.data.ok_or_else(|| {
+        anyhow::anyhow!("unexpected response from teams API: 'data' field missing")
+    })?;
     let total = teams.len();
     let exact: Vec<&datadog_api_client::datadogV2::model::Team> = teams
         .iter()
@@ -880,7 +880,11 @@ mod tests {
         let team_uuid = "00000000-0000-0000-0000-000000000001";
         mock_all(&mut s, r#"{"data": []}"#).await;
         let result = super::memberships_list(&cfg, team_uuid, 10, 0, "name".into()).await;
-        assert!(result.is_ok(), "memberships_list failed: {:?}", result.err());
+        assert!(
+            result.is_ok(),
+            "memberships_list failed: {:?}",
+            result.err()
+        );
         cleanup_env();
     }
 

src/commands/rum.rs

@@ -548,9 +548,12 @@ mod tests {
         let mut s = mockito::Server::new_async().await;
         let cfg = test_config(&s.url());
         mock_all(&mut s, r#"{"data": []}"#).await;
-        let result =
-            super::sessions_search(&cfg, None, "1h".into(), "now".into(), 25).await;
-        assert!(result.is_ok(), "rum sessions search failed: {:?}", result.err());
+        let result = super::sessions_search(&cfg, None, "1h".into(), "now".into(), 25).await;
+        assert!(
+            result.is_ok(),
+            "rum sessions search failed: {:?}",
+            result.err()
+        );
         cleanup_env();
     }
 }

src/commands/security.rs

@@ -1084,9 +1084,15 @@ mod tests {
     #[tokio::test]
     async fn test_signals_search_invalid_sort() {
         let cfg = test_config("http://unused.local");
-        let result =
-            super::signals_search(&cfg, "*".into(), "1h".into(), "now".into(), 10, Some("invalid".into()))
-                .await;
+        let result = super::signals_search(
+            &cfg,
+            "*".into(),
+            "1h".into(),
+            "now".into(),
+            10,
+            Some("invalid".into()),
+        )
+        .await;
         assert!(result.is_err());
         assert!(result
             .unwrap_err()

src/commands/traces.rs

@@ -446,16 +446,38 @@ mod tests {
     #[tokio::test]
     async fn test_search_limit_too_small() {
         let cfg = test_config("http://unused.local");
-        let result = super::search(&cfg, "*".into(), "1h".into(), "now".into(), 0, "-timestamp".into()).await;
+        let result = super::search(
+            &cfg,
+            "*".into(),
+            "1h".into(),
+            "now".into(),
+            0,
+            "-timestamp".into(),
+        )
+        .await;
         assert!(result.is_err());
-        assert!(result.unwrap_err().to_string().contains("--limit must be between 1 and 1000"));
+        assert!(result
+            .unwrap_err()
+            .to_string()
+            .contains("--limit must be between 1 and 1000"));
     }
 
     #[tokio::test]
     async fn test_search_limit_too_large() {
         let cfg = test_config("http://unused.local");
-        let result = super::search(&cfg, "*".into(), "1h".into(), "now".into(), 1001, "-timestamp".into()).await;
+        let result = super::search(
+            &cfg,
+            "*".into(),
+            "1h".into(),
+            "now".into(),
+            1001,
+            "-timestamp".into(),
+        )
+        .await;
         assert!(result.is_err());
-        assert!(result.unwrap_err().to_string().contains("--limit must be between 1 and 1000"));
+        assert!(result
+            .unwrap_err()
+            .to_string()
+            .contains("--limit must be between 1 and 1000"));
     }
 }

src/main.rs

@@ -4664,7 +4664,10 @@ enum SecuritySignalActions {
         to: String,
         #[arg(long, default_value_t = 100, help = "Maximum results (1-1000)")]
         limit: i32,
-        #[arg(long, help = "Sort order: timestamp (ascending) or -timestamp (descending)")]
+        #[arg(
+            long,
+            help = "Sort order: timestamp (ascending) or -timestamp (descending)"
+        )]
         sort: Option<String>,
     },
     /// Get log queries for investigating a signal