From ec505b22cd7d3eeddd4275e42e74d8675dea6521 Mon Sep 17 00:00:00 2001 From: Matthias Seitz Date: Thu, 25 Jul 2024 12:52:41 +0200 Subject: [PATCH] fix: set pipeline state back to idel (#9795) --- crates/engine/tree/src/backfill.rs | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) 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())