nvflare.private.fed.client.training_cmds module

class AbortAppProcessor[source]

Bases: RequestProcessor

get_topics() → List[str][source]

Get topics that this processor will handle.

Returns: list of topics

process(req: Message, app_ctx) → Message[source]

Called to process the specified request.

Parameters:

  • req – request message

  • app_ctx – application context

Returns: reply message

class AbortTaskProcessor[source]

Bases: RequestProcessor

get_topics() → List[str][source]

Get topics that this processor will handle.

Returns: list of topics

process(req: Message, app_ctx) → Message[source]

Called to process the specified request.

Parameters:

  • req – request message

  • app_ctx – application context

Returns: reply message

class ClientStatusProcessor[source]

Bases: RequestProcessor

get_topics() → List[str][source]

Get topics that this processor will handle.

Returns: list of topics

process(req: Message, app_ctx) → Message[source]

Called to process the specified request.

Parameters:

  • req – request message

  • app_ctx – application context

Returns: reply message

class DeleteRunNumberProcessor[source]

Bases: RequestProcessor

get_topics() → List[str][source]

Get topics that this processor will handle.

Returns: list of topics

process(req: Message, app_ctx) → Message[source]

Called to process the specified request.

Parameters:

  • req – request message

  • app_ctx – application context

Returns: reply message

class DeployProcessor[source]

Bases: RequestProcessor

get_topics() → List[str][source]

Get topics that this processor will handle.

Returns: list of topics

process(req: Message, app_ctx) → Message[source]

Called to process the specified request.

Parameters:

  • req – request message

  • app_ctx – application context

Returns: reply message

class NotifyJobStatusProcessor[source]

Bases: RequestProcessor

get_topics() → [<class 'str'>][source]

Get topics that this processor will handle.

Returns: list of topics

process(req: Message, app_ctx) → Message[source]

Called to process the specified request.

Parameters:

  • req – request message

  • app_ctx – application context

Returns: reply message

class RestartClientProcessor[source]

Bases: RequestProcessor

get_topics() → List[str][source]

Get topics that this processor will handle.

Returns: list of topics

process(req: Message, app_ctx) → Message[source]

Called to process the specified request.

Parameters:

  • req – request message

  • app_ctx – application context

Returns: reply message

class ScopeInfoProcessor[source]

Bases: RequestProcessor

get_topics() → List[str][source]

Get topics that this processor will handle.

Returns: list of topics

process(req: Message, app_ctx) → Message[source]

Called to process the specified request.

Parameters:

  • req – request message

  • app_ctx – application context

Returns: reply message

class ShutdownClientProcessor[source]

Bases: RequestProcessor

get_topics() → List[str][source]

Get topics that this processor will handle.

Returns: list of topics

process(req: Message, app_ctx) → Message[source]

Called to process the specified request.

Parameters:

  • req – request message

  • app_ctx – application context

Returns: reply message

class StartAppProcessor[source]

Bases: RequestProcessor

get_topics() → List[str][source]

Get topics that this processor will handle.

Returns: list of topics

process(req: Message, app_ctx) → Message[source]

Called to process the specified request.

Parameters:

  • req – request message

  • app_ctx – application context

Returns: reply message