diff --git a/src/client/src/tscSubquery.c b/src/client/src/tscSubquery.c
index ab9af695775bad3e91e6189e45e54562523bf5f6..50d9a3a56269fb57456cb478278d4cb2c060956d 100644
--- a/src/client/src/tscSubquery.c
+++ b/src/client/src/tscSubquery.c
@@ -2505,8 +2505,11 @@ void tscBuildResFromSubqueries(SSqlObj *pSql) {
     assert (pRes->row >= pRes->numOfRows);
 
     doBuildResFromSubqueries(pSql);
-    tsem_post(&pSql->rspSem);
-    return;
+    if (pRes->code == TSDB_CODE_SUCCESS) {
+      (*pSql->fp)(pSql->param, pSql, pRes->numOfRows);
+    } else {
+      tscQueueAsyncRes(pSql);
+    }
   }
 }