diff --git a/source/libs/transport/src/transCli.c b/source/libs/transport/src/transCli.c index c347cc61cb..4cef50016e 100644 --- a/source/libs/transport/src/transCli.c +++ b/source/libs/transport/src/transCli.c @@ -2502,12 +2502,12 @@ bool cliMayRetry(SCliConn* pConn, SCliReq* pReq, STransMsg* pResp) { SReqCtx* pCtx = pReq->ctx; int32_t code = pResp->code; - cliRetryMayInitCtx(pInst, pReq); - if (pReq->msg.info.qId != 0) { return false; } + cliRetryMayInitCtx(pInst, pReq); + if (!cliRetryShouldRetry(pInst, pResp)) { return false; }