diff --git a/nvflare/apis/fl_constant.py b/nvflare/apis/fl_constant.py index d9e0e92315..1728a83ca8 100644 --- a/nvflare/apis/fl_constant.py +++ b/nvflare/apis/fl_constant.py @@ -265,7 +265,6 @@ class ServerCommandNames(object): HANDLE_DEAD_JOB = "handle_dead_job" SERVER_STATE = "server_state" APP_COMMAND = "app_command" - CONFIGURE_JOB_LOG = "configure_job_log" class ServerCommandKey(object): diff --git a/nvflare/private/fed/server/server_commands.py b/nvflare/private/fed/server/server_commands.py index 372ec82bdf..b61cc953ae 100644 --- a/nvflare/private/fed/server/server_commands.py +++ b/nvflare/private/fed/server/server_commands.py @@ -429,10 +429,10 @@ class ConfigureJobLogCommand(CommandProcessor): def get_command_name(self) -> str: """To get the command name. - Returns: ServerCommandNames.CONFIGURE_JOB_LOG + Returns: AdminCommandNames.CONFIGURE_JOB_LOG """ - return ServerCommandNames.CONFIGURE_JOB_LOG + return AdminCommandNames.CONFIGURE_JOB_LOG def process(self, data: Shareable, fl_ctx: FLContext): """Called to process the configure_job_log command. diff --git a/nvflare/private/fed/server/server_engine.py b/nvflare/private/fed/server/server_engine.py index 5b96a99471..3118ac9bb1 100644 --- a/nvflare/private/fed/server/server_engine.py +++ b/nvflare/private/fed/server/server_engine.py @@ -865,7 +865,7 @@ def configure_job_log(self, job_id, data) -> dict: try: self.send_command_to_child_runner_process( job_id=job_id, - command_name=ServerCommandNames.CONFIGURE_JOB_LOG, + command_name=AdminCommandNames.CONFIGURE_JOB_LOG, command_data=data, ) except Exception as ex: