xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix: return code issue

This commit is contained in:
dapan1121 2024-12-23 10:00:46 +08:00
parent 8892920ebc
commit a8a2b01f72
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
source/libs/scheduler/src/schTask.c
View File

@ -437,7 +437,7 @@ void schResetTaskForRetry(SSchJob *pJob, SSchTask *pTask) {
pTask->waitRetry = true; pTask->waitRetry = true;
if (pTask->delayTimer) { if (pTask->delayTimer) {
taosTmrStop(pTask->delayTimer); (void)taosTmrStop(pTask->delayTimer);
} }
schDropTaskOnExecNode(pJob, pTask); schDropTaskOnExecNode(pJob, pTask);
@ -761,7 +761,7 @@ int32_t schHandleTaskRetry(SSchJob *pJob, SSchTask *pTask) {
(void)atomic_sub_fetch_32(&pTask->level->taskLaunchedNum, 1); (void)atomic_sub_fetch_32(&pTask->level->taskLaunchedNum, 1);
if (pTask->delayTimer) { if (pTask->delayTimer) {
taosTmrStop(pTask->delayTimer); (void)taosTmrStop(pTask->delayTimer);
} }
(void)schRemoveTaskFromExecList(pJob, pTask); // ignore error (void)schRemoveTaskFromExecList(pJob, pTask); // ignore error