fix: notify sub job issue

dapan1121 · dapan1121 · commit 019d380cc38a · 2026-01-29T08:27:17.000+08:00
diff --git a/source/libs/scheduler/src/schJob.c b/source/libs/scheduler/src/schJob.c
@@ -829,7 +829,7 @@ int32_t schNotifyJobAllTasks(SSchJob *pJob, SSchTask *pTask, ETaskNotifyType typ
       continue;
     }
 
-    SCH_ERR_RET(schNotifyTaskInHashList(pJob, pJob->execTasks, type, NULL));
+    SCH_ERR_RET(schNotifyTaskInHashList(pSub, pSub->execTasks, type, NULL));
   }  
 
   return code;

Original file line number	Diff line number	Diff line change
`@@ -829,7 +829,7 @@ int32_t schNotifyJobAllTasks(SSchJob pJob, SSchTask pTask, ETaskNotifyType typ`
`829`	`829`	`continue;`
`830`	`830`	`}`
`831`	`831`
`832`		`- SCH_ERR_RET(schNotifyTaskInHashList(pJob, pJob->execTasks, type, NULL));`
	`832`	`+ SCH_ERR_RET(schNotifyTaskInHashList(pSub, pSub->execTasks, type, NULL));`
`833`	`833`	`}`
`834`	`834`
`835`	`835`	`return code;`