Fix procmgr CI: rustfmt, clippy, and ddot e2e log expectation.

Align restart-policy log assertion with the current message format and
resolve rustfmt/clippy failures on the spawn-profiles branch.

Author: jose-manuel-almaza

pkg/procmgr/rust/src/manager.rs

@@ -83,14 +83,11 @@ impl ProcessManager {
         let mut procs = self.processes.write().await;
         for &idx in order.iter() {
             let proc = &mut procs[idx];
-            if proc.may_auto_start() {
-                match proc.spawn() {
-                    Ok(()) => spawn_watcher(proc, exit_tx.clone()),
-                    Err(e) => {
-                        warn!("{e:#}");
-                        queue_restart(proc, restart_tx);
-                    }
-                }
+            if proc.may_auto_start()
+                && let Err(e) = try_spawn_and_watch(proc, exit_tx)
+            {
+                warn!("{e:#}");
+                queue_restart(proc, restart_tx);
             }
             proc.record_config_gate_met();
         }
@@ -905,10 +902,7 @@ fn queue_restart(proc: &mut ManagedProcess, restart_tx: &mpsc::Sender<PendingRes
     }
 }
 
-fn try_spawn_and_watch(
-    proc: &mut ManagedProcess,
-    exit_tx: &mpsc::Sender<ExitEvent>,
-) -> Result<()> {
+fn try_spawn_and_watch(proc: &mut ManagedProcess, exit_tx: &mpsc::Sender<ExitEvent>) -> Result<()> {
     proc.spawn()?;
     spawn_watcher(proc, exit_tx.clone());
     Ok(())
@@ -1149,14 +1143,16 @@ mod tests {
             "reload should start the process with fresh counters"
         );
 
-        mgr.complete_restart(stale_pending, &exit_tx, &restart_tx).await;
+        mgr.complete_restart(stale_pending, &exit_tx, &restart_tx)
+            .await;
         let pid = mgr.processes().await[0].pid().unwrap();
         test_helpers::cleanup_process(pid);
         Ok(())
     }
 
     #[tokio::test]
-    async fn test_reload_discards_pending_retry_for_failed_auto_start_false() -> anyhow::Result<()> {
+    async fn test_reload_discards_pending_retry_for_failed_auto_start_false() -> anyhow::Result<()>
+    {
         let (cmd, _args) = test_helpers::sleep_cmd(60);
         let make_def = |secs: u32| ProcessDefinition {
             name: "action-executor".to_string(),
@@ -1203,7 +1199,8 @@ mod tests {
         mgr.handle_reload_config(&exit_tx, &restart_tx).await?;
         assert!(!mgr.processes().await[0].is_running());
 
-        mgr.complete_restart(stale_pending, &exit_tx, &restart_tx).await;
+        mgr.complete_restart(stale_pending, &exit_tx, &restart_tx)
+            .await;
         assert!(
             !mgr.processes().await[0].is_running(),
             "config reload should discard pending crash retries for failed auto_start=false processes"

pkg/procmgr/rust/src/platform/windows/agent_credentials.rs

@@ -3,7 +3,6 @@
 // This product includes software developed at Datadog (https://www.datadoghq.com/).
 // Copyright 2026-present Datadog, Inc.
 
-
 use anyhow::{Context, Result, bail};
 use std::ptr;
 use windows_sys::Win32::Security::Authentication::Identity::{
@@ -34,7 +33,10 @@ pub(crate) enum AgentAccount {
         user: String,
         password: String,
     },
-    ServiceAccountLogon { domain: String, user: String },
+    ServiceAccountLogon {
+        domain: String,
+        user: String,
+    },
 }
 
 impl AgentAccount {

pkg/procmgr/rust/src/platform/windows/agent_service_sid.rs

@@ -3,7 +3,6 @@
 // This product includes software developed at Datadog (https://www.datadoghq.com/).
 // Copyright 2026-present Datadog, Inc.
 
-
 use anyhow::{Context, Result, bail};
 use std::ptr;
 use windows_sys::Win32::System::Services::{

pkg/procmgr/rust/src/platform/windows/legacy_scm_env.rs

@@ -3,7 +3,6 @@
 // This product includes software developed at Datadog (https://www.datadoghq.com/).
 // Copyright 2026-present Datadog, Inc.
 
-
 use std::collections::HashMap;
 use std::sync::Mutex;
 

pkg/procmgr/rust/src/platform/windows/local_account.rs

@@ -3,7 +3,6 @@
 // This product includes software developed at Datadog (https://www.datadoghq.com/).
 // Copyright 2026-present Datadog, Inc.
 
-
 use anyhow::{Context, Result, bail};
 use std::ptr;
 use windows_sys::Win32::Foundation::{ERROR_INSUFFICIENT_BUFFER, WIN32_ERROR};

pkg/procmgr/rust/src/platform/windows/managed_service_account.rs

@@ -3,7 +3,6 @@
 // This product includes software developed at Datadog (https://www.datadoghq.com/).
 // Copyright 2026-present Datadog, Inc.
 
-
 use anyhow::{Context, Result, bail};
 use std::ptr;
 use windows_sys::Win32::Foundation::{

pkg/procmgr/rust/src/platform/windows/pipe_caller.rs

@@ -3,7 +3,6 @@
 // This product includes software developed at Datadog (https://www.datadoghq.com/).
 // Copyright 2026-present Datadog, Inc.
 
-
 use windows_sys::Win32::Foundation::{HANDLE, TRUE};
 use windows_sys::Win32::Security::{
     AllocateAndInitializeSid, EqualSid, FreeSid, GetTokenInformation, IsWellKnownSid, RevertToSelf,

pkg/procmgr/rust/src/platform/windows/pipe_security.rs

@@ -3,7 +3,6 @@
 // This product includes software developed at Datadog (https://www.datadoghq.com/).
 // Copyright 2026-present Datadog, Inc.
 
-
 use std::ffi::OsStr;
 use std::io;
 use std::ptr;

pkg/procmgr/rust/src/platform/windows/scm_service.rs

@@ -3,7 +3,6 @@
 // This product includes software developed at Datadog (https://www.datadoghq.com/).
 // Copyright 2026-present Datadog, Inc.
 
-
 use std::ffi::c_void;
 use std::path::PathBuf;
 use std::sync::Arc;

pkg/procmgr/rust/src/platform/windows/sid.rs

@@ -3,7 +3,6 @@
 // This product includes software developed at Datadog (https://www.datadoghq.com/).
 // Copyright 2026-present Datadog, Inc.
 
-
 use anyhow::{Result, bail};
 use std::ptr;
 use windows_sys::Win32::Security::Authorization::ConvertSidToStringSidW;