From fbf864e92860fe2a85016f5c234232af4cd5909a Mon Sep 17 00:00:00 2001
From: abingcbc <abingcbc626@gmail.com>
Date: Wed, 25 Dec 2024 10:41:49 +0800
Subject: [PATCH] fix

---
 core/runner/ProcessorRunner.cpp | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/core/runner/ProcessorRunner.cpp b/core/runner/ProcessorRunner.cpp
index 8b32e42b2d..465c81aa42 100644
--- a/core/runner/ProcessorRunner.cpp
+++ b/core/runner/ProcessorRunner.cpp
@@ -145,13 +145,13 @@ void ProcessorRunner::Run(uint32_t threadNo) {
         if (hasOldPipeline) {
             pipeline->SubInProcessCnt(); // old pipeline
             pipeline = PipelineManager::GetInstance()->FindConfigByName(configName); // update to new pipeline
-            pipeline->AddInProcessCnt();
             if (!pipeline) {
                 LOG_INFO(sLogger,
                          ("pipeline not found during processing, perhaps due to config deletion",
                           "discard data")("config", configName));
                 continue;
             }
+            pipeline->AddInProcessCnt();
         }
 
         if (pipeline->IsFlushingThroughGoPipeline()) {