From e980b6013eebdc1dee537f94316339e65245a2a0 Mon Sep 17 00:00:00 2001 From: Yuhong Wen Date: Tue, 9 Apr 2024 20:27:09 -0400 Subject: [PATCH 1/2] Added more logging for the job status changing. --- nvflare/private/fed/server/job_runner.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/nvflare/private/fed/server/job_runner.py b/nvflare/private/fed/server/job_runner.py index 15a9bea833..480fea34eb 100644 --- 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: From 99595b124e647f42d5c120c0c381d37c798d4173 Mon Sep 17 00:00:00 2001 From: Yuhong Wen Date: Wed, 10 Apr 2024 10:53:25 -0400 Subject: [PATCH 2/2] Fixed a logging call error. --- nvflare/private/fed/server/job_runner.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/nvflare/private/fed/server/job_runner.py b/nvflare/private/fed/server/job_runner.py index 480fea34eb..d6bf91e888 100644 --- a/nvflare/private/fed/server/job_runner.py +++ b/nvflare/private/fed/server/job_runner.py @@ -444,7 +444,7 @@ def run(self, fl_ctx: FLContext): }, fl_ctx, ) - self.log_info(f"Updated the schedule history of Job: {job_id}") + self.log_info(fl_ctx, 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}