nvflare.app_common.launchers.subprocess_launcher module

class SubprocessLauncher(script: str, launch_once: bool | None = True, clean_up_script: str | None = None, shutdown_timeout: float | None = 0.0)

Bases: Launcher

Initializes the SubprocessLauncher.

Parameters:

• script (str) – Script to be launched using subprocess.

• launch_once (bool) – Whether the external process will be launched only once at the beginning or on each task.

• clean_up_script (Optional[str]) – Optional clean up script to be run after the main script execution.

• shutdown_timeout (float) – If provided, the system will wait for this number of seconds before shutting down. 0.0 means an immediate timeout.

check_run_status(task_name: str, fl_ctx: FLContext) → str

Checks the run status of Launcher.

finalize(fl_ctx: FLContext) → None

initialize(fl_ctx: FLContext)

launch_task(task_name: str, shareable: Shareable, fl_ctx: FLContext, abort_signal: Signal) → bool

Launches external system to handle a task.

Parameters:

• task_name (str) – task name.

• shareable (Shareable) – input shareable.

• fl_ctx (FLContext) – fl context.

• abort_signal (Signal) – signal to check during execution to determine whether this task is aborted.

Returns:

Whether launch success or not.

stop_task(task_name: str, fl_ctx: FLContext, abort_signal: Signal) → None

Stops external system and free up resources.

Parameters:

• task_name (str) – task name.

• fl_ctx (FLContext) – fl context.

get_line(buffer: bytearray)

Read a line from the binary buffer. It treats all combinations of and as line breaks.

Args:

buffer: A binary buffer

Returns:

(line, remaining): Return the first line as str and the remaining buffer. line is None if no newline found

log_subprocess_output(process, logger)