From 3c679525e2f973d206b5c5e39565487169b4cdab Mon Sep 17 00:00:00 2001
From: Paul Masurel <paul@quickwit.io>
Date: Thu, 10 Oct 2024 12:35:02 +0900
Subject: [PATCH] Sending the right message in indexing service

---
 quickwit/quickwit-indexing/src/actors/indexing_service.rs | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/quickwit/quickwit-indexing/src/actors/indexing_service.rs b/quickwit/quickwit-indexing/src/actors/indexing_service.rs
index 7f50f9c3ad7..7347ffe0250 100644
--- a/quickwit/quickwit-indexing/src/actors/indexing_service.rs
+++ b/quickwit/quickwit-indexing/src/actors/indexing_service.rs
@@ -65,6 +65,7 @@ use tracing::{debug, error, info, warn};
 
 use super::merge_pipeline::{MergePipeline, MergePipelineParams};
 use super::{MergePlanner, MergeSchedulerService};
+use crate::actors::merge_pipeline::FinishPendingMergesAndShutdownPipeline;
 use crate::models::{DetachIndexingPipeline, DetachMergePipeline, ObservePipeline, SpawnPipeline};
 use crate::source::{AssignShards, Assignment};
 use crate::split_store::{LocalSplitStore, SplitStoreQuota};
@@ -517,7 +518,7 @@ impl IndexingService {
                 merge_pipeline_handle
                     .handle
                     .mailbox()
-                    .send_message(Command::Quit)
+                    .send_message(FinishPendingMergesAndShutdownPipeline)
                     .await
                     .expect("merge pipeline mailbox should not be full");
             }