nvflare.private.fed.server.server_state module

class Cold2HotState(host: str = '', port: str = '', ssid: str = '')[source]

Bases: ServerState

aux_communicate(fl_ctx: FLContext) → dict[source]
get_task(fl_ctx: FLContext) → dict[source]
handle_sd_callback(sp: SP, fl_ctx: FLContext) → ServerState[source]
heartbeat(fl_ctx: FLContext) → dict[source]
register(fl_ctx: FLContext) → dict[source]
submit_result(fl_ctx: FLContext) → dict[source]
class ColdState(host: str = '', port: str = '', ssid: str = '')[source]

Bases: ServerState

aux_communicate(fl_ctx: FLContext) → dict[source]
get_task(fl_ctx: FLContext) → dict[source]
handle_sd_callback(sp: SP, fl_ctx: FLContext) → ServerState[source]
heartbeat(fl_ctx: FLContext) → dict[source]
register(fl_ctx: FLContext) → dict[source]
submit_result(fl_ctx: FLContext) → dict[source]
class Hot2ColdState(host: str = '', port: str = '', ssid: str = '')[source]

Bases: ServerState

aux_communicate(fl_ctx: FLContext) → dict[source]
get_task(fl_ctx: FLContext) → dict[source]
handle_sd_callback(sp: SP, fl_ctx: FLContext) → ServerState[source]
heartbeat(fl_ctx: FLContext) → dict[source]
register(fl_ctx: FLContext) → dict[source]
submit_result(fl_ctx: FLContext) → dict[source]
class HotState(host: str = '', port: str = '', ssid: str = '')[source]

Bases: ServerState

aux_communicate(fl_ctx: FLContext) → dict[source]
get_task(fl_ctx: FLContext) → dict[source]
handle_sd_callback(sp: SP, fl_ctx: FLContext) → ServerState[source]
heartbeat(fl_ctx: FLContext) → dict[source]
register(fl_ctx: FLContext) → dict[source]
submit_result(fl_ctx: FLContext) → dict[source]
class ServerState(host: str = '', port: str = '', ssid: str = '')[source]

Bases: object

ABORT_CURRENT_RUN = {'_action': 'Abort Run', '_messsage': 'Abort current run'}
IN_SSERVICE = {'_action': 'In Service', '_messsage': 'Server in service'}
NOT_IN_SERVICE = {'_action': 'Not In Service', '_messsage': 'Server not in service'}
aux_communicate(fl_ctx: FLContext) → dict[source]
get_task(fl_ctx: FLContext) → dict[source]
handle_sd_callback(sp: SP, fl_ctx: FLContext) → ServerState[source]
heartbeat(fl_ctx: FLContext) → dict[source]
register(fl_ctx: FLContext) → dict[source]
submit_result(fl_ctx: FLContext) → dict[source]
class ServiceSession(host: str = '', port: str = '', ssid: str = '')[source]

Bases: object

class ShutdownState(host: str = '', port: str = '', ssid: str = '')[source]

Bases: ServerState

aux_communicate(fl_ctx: FLContext) → dict[source]
get_task(fl_ctx: FLContext) → dict[source]
handle_sd_callback(sp: SP, fl_ctx: FLContext) → ServerState[source]
heartbeat(fl_ctx: FLContext) → dict[source]
register(fl_ctx: FLContext) → dict[source]
submit_result(fl_ctx: FLContext) → dict[source]