submit_dataloading_job should return job_id not scheduler_id

Committed-by: xiaolei.zl from Dev container
alibaba · Dec 16, 2024 · 4d02e80 · 4d02e80
1 parent bbe9295
commit 4d02e80
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/coordinator/gscoordinator/flex/core/insight/groot.py b/coordinator/gscoordinator/flex/core/insight/groot.py
@@ -178,7 +178,7 @@ def submit_dataloading_job(
         job_scheduler = DataloadingJobScheduler(
             config, ds_manager, self._job_status, self._graph, at_time, repeat
         )
-        return job_scheduler.schedulerid
+        return job_scheduler.jobid
 
     def get_dataloading_job_config(
         self, graph_id: str, config: dict, ds_manager: DataSourceManager