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

fix: task reschedule issue

This commit is contained in:
dapan1121 2024-09-27 13:32:28 +08:00
parent 116f06d028
commit 9a7fec10af
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -358,6 +358,11 @@ int32_t schRescheduleTask(SSchJob *pJob, SSchTask *pTask) {
int32_t schChkUpdateRedirectCtx(SSchJob *pJob, SSchTask *pTask, SEpSet *pEpSet, int32_t rspCode) { int32_t schChkUpdateRedirectCtx(SSchJob *pJob, SSchTask *pTask, SEpSet *pEpSet, int32_t rspCode) {
SSchRedirectCtx *pCtx = &pTask->redirectCtx; SSchRedirectCtx *pCtx = &pTask->redirectCtx;
if (JOB_TASK_STATUS_EXEC == pTask->status) {
SCH_TASK_DLOG("task not start yet, rspCode:%d", rspCode);
return TSDB_CODE_SUCCESS;
}
if (!pCtx->inRedirect) { if (!pCtx->inRedirect) {
pCtx->inRedirect = true; pCtx->inRedirect = true;
pCtx->periodMs = tsRedirectPeriod; pCtx->periodMs = tsRedirectPeriod;