From f0760a3bb03404253161bd559c60e7365da33230 Mon Sep 17 00:00:00 2001
From: dapan1121 <wpan@taosdata.com>
Date: Fri, 1 Nov 2024 16:17:10 +0800
Subject: [PATCH] fix: msg preprocess fail issue

---
 source/libs/qworker/src/qwMsg.c   | 2 +-
 source/libs/qworker/src/qworker.c | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/source/libs/qworker/src/qwMsg.c b/source/libs/qworker/src/qwMsg.c
index 69014d5b1c..20b81bfc14 100644
--- a/source/libs/qworker/src/qwMsg.c
+++ b/source/libs/qworker/src/qwMsg.c
@@ -429,7 +429,7 @@ int32_t qWorkerPreprocessQueryMsg(void *qWorkerMgmt, SRpcMsg *pMsg, bool chkGran
 
   tFreeSSubQueryMsg(&msg);
 
-  return TSDB_CODE_SUCCESS;
+  return code;
 }
 
 int32_t qWorkerAbortPreprocessQueryMsg(void *qWorkerMgmt, SRpcMsg *pMsg) {
diff --git a/source/libs/qworker/src/qworker.c b/source/libs/qworker/src/qworker.c
index ddc4812b55..9b96c1e519 100644
--- a/source/libs/qworker/src/qworker.c
+++ b/source/libs/qworker/src/qworker.c
@@ -751,7 +751,7 @@ _return:
     qwReleaseTaskCtx(mgmt, ctx);
   }
 
-  return TSDB_CODE_SUCCESS;
+  return code;
 }
 
 int32_t qwProcessQuery(QW_FPARAMS_DEF, SQWMsg *qwMsg, char *sql) {