nvflare.private.fed.client.scheduler_cmds module

class CancelResourceProcessor[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 CheckResourceProcessor[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 ReportResourcesProcessor[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 StartJobProcessor[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