diff --git a/crates/engine/tree/src/backfill.rs b/crates/engine/tree/src/backfill.rs index 42e2df6be5..0cea1933ed 100644 --- a/crates/engine/tree/src/backfill.rs +++ b/crates/engine/tree/src/backfill.rs @@ -139,7 +139,10 @@ where } }; let ev = match res { - Ok((_, result)) => BackfillEvent::Finished(result), + Ok((pipeline, result)) => { + self.pipeline_state = PipelineState::Idle(Some(pipeline)); + BackfillEvent::Finished(result) + } Err(why) => { // failed to receive the pipeline BackfillEvent::TaskDropped(why.to_string())