nvflare.private.fed.app.client.sub_worker_process module

Sub_worker process to start the multi-processes client.

class EventRelayer(conn, local_rank)

Bases: FLComponent

To relay the event from the worker_process.

To init the EventRelayer.

Parameters

• conn – worker_process connection.

• local_rank – process local rank

handle_event(event_type: str, fl_ctx: FLContext)

To handle the event.

Parameters

• event_type – event_type

• fl_ctx – FLContext

relay_event(run_manager, data)

To relay the event.

Parameters

• run_manager – Client_Run_Manager

• data – event data

execute(run_manager, local_rank, exe_conn, executor)

To execute the event task and pass to worker_process.

Parameters

• run_manager – Client_Run_Manager

• local_rank – provcess local rank

• exe_conn – execution connection

• executor – local executor

handle_event(run_manager, local_rank, exe_conn)

To handle the event.

Parameters

• run_manager – Client_run_manager

• local_rank – process local rank

• exe_conn – execute connection

main()

Sub_worker process program.