Skip to content

Commit 2eabcbc

Browse files
committed
style(v0.4.10): cargo fmt --all
1 parent 51a592b commit 2eabcbc

2 files changed

Lines changed: 3 additions & 13 deletions

File tree

crates/orchestrator-daemon-runtime/src/control/dispatch.rs

Lines changed: 2 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -527,9 +527,7 @@ impl ControlSurface for InProcessSurface {
527527
Ok(v) => v,
528528
Err(_) => Vec::new(),
529529
};
530-
let probes = discovered.into_iter().map(|p| async move {
531-
probe_plugin_health(&p).await
532-
});
530+
let probes = discovered.into_iter().map(|p| async move { probe_plugin_health(&p).await });
533531
let plugins: Vec<PluginHealth> = futures_util::future::join_all(probes).await;
534532
Ok(DaemonHealthResponse { status: DaemonHealthStatus::Healthy, plugins, last_error: None })
535533
}
@@ -949,13 +947,7 @@ async fn probe_plugin_health(plugin: &orchestrator_plugin_host::DiscoveredPlugin
949947
animus_plugin_protocol::HealthStatus::Degraded => DaemonHealthStatus::Degraded,
950948
animus_plugin_protocol::HealthStatus::Unhealthy => DaemonHealthStatus::Unhealthy,
951949
};
952-
PluginHealth {
953-
name,
954-
kind,
955-
status,
956-
uptime_ms: result.uptime_ms,
957-
last_error: result.last_error,
958-
}
950+
PluginHealth { name, kind, status, uptime_ms: result.uptime_ms, last_error: result.last_error }
959951
}
960952
Ok(Err(err)) => PluginHealth {
961953
name,

crates/orchestrator-web-api/src/services/web_api_service/workflows_handlers.rs

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -753,9 +753,7 @@ async fn try_workflow_cancel_via_control(project_root: &str, id: &str) -> Option
753753
// from an operator's standpoint. Local-only fields (phases, machine
754754
// state, decision history, current_phase) are intentionally dropped.
755755

756-
fn workflow_to_run_summary(
757-
w: OrchestratorWorkflow,
758-
) -> animus_control_protocol::types::WorkflowRunSummary {
756+
fn workflow_to_run_summary(w: OrchestratorWorkflow) -> animus_control_protocol::types::WorkflowRunSummary {
759757
use animus_control_protocol::types::{WorkflowRunSummary, WorkflowStatus as WireStatus};
760758
use animus_subject_protocol::SubjectId as WireSubjectId;
761759
use protocol::orchestrator::WorkflowStatus as LocalStatus;

0 commit comments

Comments
 (0)