This commit is contained in:
Bryan Helmkamp 2026-04-15 10:15:33 -04:00
parent 2db50966e8
commit 3a97c1fdd9
No known key found for this signature in database
2 changed files with 4 additions and 6 deletions

View file

@ -73,7 +73,7 @@ impl Provider {
/// Pick the best default provider based on an explicit configured list.
#[must_use]
pub fn default_for_configured(configured: &[Self]) -> Self {
Self::default_with(|provider| configured.contains(&provider))
Self::default_with(|p| configured.contains(&p))
}
/// Testable core of [`default_from_env`]: walks the precedence list and

View file

@ -2148,10 +2148,7 @@ async fn list_run_stages(
// The checkpoint's current_node is the last *completed* stage; next_node_id
// is the stage that is currently executing.
if let Some(next_id) = &checkpoint.next_node_id {
if run_is_active
&& next_id != "exit"
&& !checkpoint.completed_nodes.contains(next_id)
{
if run_is_active && next_id != "exit" && !checkpoint.completed_nodes.contains(next_id) {
stages.push(RunStage {
id: next_id.clone(),
name: next_id.clone(),
@ -6517,7 +6514,8 @@ async fn get_graph(
};
let live_dot_source = {
let runs = state.runs.lock().expect("runs lock poisoned");
runs.get(&id).map(|managed_run| managed_run.dot_source.clone())
runs.get(&id)
.map(|managed_run| managed_run.dot_source.clone())
};
if let Some(dot) = &live_dot_source {
if !dot.is_empty() {