Skip to content

Commit 8dcac91

Browse files
yhwenchesterxgchen
andauthored
[2.4] Added more logging for the job status changing (#2481)
* Added more logging for the job status changing. * Fixed a logging call error. * Added more logging for the job status change. --------- Co-authored-by: Chester Chen <[email protected]>
1 parent 06514a4 commit 8dcac91

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

nvflare/private/fed/server/job_runner.py

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -443,6 +443,7 @@ def run(self, fl_ctx: FLContext):
443443
},
444444
fl_ctx,
445445
)
446+
self.log_info(fl_ctx, f"Updated the schedule history of Job: {job_id}")
446447

447448
if failed_clients:
448449
deployable_clients = {k: v for k, v in client_sites.items() if k not in failed_clients}
@@ -455,15 +456,19 @@ def run(self, fl_ctx: FLContext):
455456
)
456457
continue
457458

459+
self.log_info(fl_ctx, f"Start to the run Job: {job_id}")
458460
self._start_run(
459461
job_id=job_id,
460462
job=ready_job,
461463
client_sites=deployable_clients,
462464
fl_ctx=fl_ctx,
463465
)
466+
self.log_info(fl_ctx, f"Job: {job_id} has been started.")
464467
with self.lock:
465468
self.running_jobs[job_id] = ready_job
469+
self.log_info(fl_ctx, f"About to change the Job: {job_id} status to RUNNING.")
466470
job_manager.set_status(ready_job.job_id, RunStatus.RUNNING, fl_ctx)
471+
self.log_info(fl_ctx, f"Job: {job_id} started to run, status changed to RUNNING.")
467472
except Exception as e:
468473
if job_id:
469474
if job_id in self.running_jobs:

0 commit comments

Comments
 (0)