Skip to content

Commit

Permalink
reuse AdminCommandNames
Browse files Browse the repository at this point in the history
  • Loading branch information
SYangster committed Jan 6, 2025
1 parent 62301b9 commit 2db250d
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 4 deletions.
1 change: 0 additions & 1 deletion nvflare/apis/fl_constant.py
Original file line number Diff line number Diff line change
Expand Up @@ -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):
Expand Down
4 changes: 2 additions & 2 deletions nvflare/private/fed/server/server_commands.py
Original file line number Diff line number Diff line change
Expand Up @@ -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.
Expand Down
2 changes: 1 addition & 1 deletion nvflare/private/fed/server/server_engine.py
Original file line number Diff line number Diff line change
Expand Up @@ -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:
Expand Down

0 comments on commit 2db250d

Please sign in to comment.