local#

class LocalBackend(cfg: dict[str, Any] | None = None)#

Bases: Backend

type: str = 'local'#
classmethod matches(arg: str) bool#
property resource_specs: list[dict]#
property valid_launchers: set[str]#
classmethod default_config() dict[str, Any]#

Return a complete default configuration for this backend.

submission_manager() HPCSubmissionManager#
launcher() HPCLauncher#
discover() list[dict[str, Any]]#
class SubprocessAdapter(config: dict[str, Any])#

Bases: object

polling_interval() float#
prepare(spec: JobSpec) JobSpec#
submit(spec: JobSpec, exclusive: bool = True) Subprocess#
class Subprocess(args: list[str], output: str | None, error: str | None, emit_interval: float = 300.0)#

Bases: HPCProcess

last_debug_emit: float#
emit_interval: float#
property returncode: int | None#
poll() int | None#
cancel() None#

Kill a process tree (including grandchildren)

streamify(arg: str | None) TextIO | None#
hpc_connect_backend() Type[LocalBackend]#