nvflare.private.fed.server.run_manager module

class RunManager(server_name, engine: ~nvflare.apis.server_engine_spec.ServerEngineSpec, job_id, workspace: ~nvflare.apis.workspace.Workspace, components: {<class 'str'>: <class 'nvflare.apis.fl_component.FLComponent'>}, client_manager: ~nvflare.private.fed.server.client_manager.ClientManager | None = None, handlers: ~typing.List[~nvflare.apis.fl_component.FLComponent] | None = None)

Bases: EngineSpec

Manage run.

Parameters:

• server_name – server name

• engine (ServerEngineSpec) – server engine

• job_id – job id

• workspace (Workspace) – workspace

• components (dict) – A dict of extra python objects {id: object}

• client_manager (ClientManager, optional) – client manager

• handlers (List[FLComponent], optional) – handlers

add_component(component_id: str, component)

add_handler(handler: FLComponent)

create_job_processing_context_properties(workspace, job_id)

fire_event(event_type: str, fl_ctx: FLContext)

get_cell()

get_component(component_id: str) → object

get_handlers()

get_run_info() → RunInfo

get_server_name()

get_workspace() → Workspace

new_context() → FLContext

validate_targets(client_names: List[str]) → Tuple[List[Client], List[str]]

Validate specified target names.

Parameters:

target_names – list of names to be validated

Returns: a list of validate targets and a list of invalid target names