Added more logging for the job status changing.

NVIDIA · Apr 10, 2024 · e980b60 · e980b60
1 parent 656cec6
commit e980b60
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/nvflare/private/fed/server/job_runner.py b/nvflare/private/fed/server/job_runner.py
@@ -444,6 +444,7 @@ def run(self, fl_ctx: FLContext):
                                     },
                                     fl_ctx,
                                 )
+                                self.log_info(f"Updated the schedule history of Job: {job_id}")
 
                             if failed_clients:
                                 deployable_clients = {k: v for k, v in client_sites.items() if k not in failed_clients}
@@ -465,6 +466,7 @@ def run(self, fl_ctx: FLContext):
                             with self.lock:
                                 self.running_jobs[job_id] = ready_job
                             job_manager.set_status(ready_job.job_id, RunStatus.RUNNING, fl_ctx)
+                            self.log_info(fl_ctx, f"Job: {job_id} started to run, status changed to RUNNING.")
                         except Exception as e:
                             if job_id:
                                 if job_id in self.running_jobs: