From 06ba3027b10cc84a359140b1803bb499d483e40a Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Sun, 2 Mar 2025 12:06:19 +0800
Subject: [PATCH] fix(stream): check return value.

---
 source/dnode/vnode/src/tqCommon/tqCommon.c | 8 +++++++-
 tests/ci/func.txt                          | 2 +-
 2 files changed, 8 insertions(+), 2 deletions(-)

diff --git a/source/dnode/vnode/src/tqCommon/tqCommon.c b/source/dnode/vnode/src/tqCommon/tqCommon.c
index 2b86ec8264..efd847a1f3 100644
--- a/source/dnode/vnode/src/tqCommon/tqCommon.c
+++ b/source/dnode/vnode/src/tqCommon/tqCommon.c
@@ -1011,10 +1011,16 @@ int32_t tqStreamTaskProcessAllTaskStopReq(SStreamMeta* pMeta, SMsgCb* pMsgCb, SR
   // stop all stream tasks, only invoked when trying to drop db
   if (req.streamId <= 0) {
     tqDebug("vgId:%d recv msg to stop all tasks in sync before dropping vnode", vgId);
-    streamMetaStopAllTasks(pMeta);
+    code = streamMetaStopAllTasks(pMeta);
+    if (code) {
+      tqError("vgId:%d failed to stop all tasks, code:%s", vgId, tstrerror(code));
+    }
+
   } else {  // stop only one stream tasks
 
   }
+
+  // always return success
   return TSDB_CODE_SUCCESS;
 }
 
diff --git a/tests/ci/func.txt b/tests/ci/func.txt
index 45d4fb1c11..52df0aad96 100644
--- a/tests/ci/func.txt
+++ b/tests/ci/func.txt
@@ -409,7 +409,7 @@
 (void)tqProcessTaskConsenChkptIdReq
 (void)tqProcessTaskResetReq
 (void)tqScanWalAsync
-(void)tqStopStreamTasksAsync
+(void)tqStopStreamAllTasksAsync
 (void)tqUpdateTbUidList
 (void)transAcquireExHandle
 (void)transAsyncSend