jobflow_remote.jobs.daemon module

exception jobflow_remote.jobs.daemon.DaemonError

Bases: Exception

class jobflow_remote.jobs.daemon.DaemonManager(daemon_dir: str | Path, log_dir: str | Path, project: Project)

Bases: object

check_status() → DaemonStatus

check_supervisord_process() → bool

clean_files() → None

property conf_filepath: Path

conf_template_single = <string.Template object>

conf_template_split = <string.Template object>

foreground_process(name, print_function: Callable | None = None) → None

foreground_processes(processes_names: list | None = None, print_function: Callable | None = None) → None

classmethod from_project(project: Project)

classmethod from_project_name(project_name: str | None = None)

get_controller()

get_interface()

get_processes_info() → dict[str, dict] | None

get_supervisord_pid() → int | None

kill(raise_on_error: bool = False) → bool

property log_filepath: Path

property pid_filepath: Path

shut_down(raise_on_error: bool = False) → bool

property sock_filepath: Path

start(num_procs_transfer: int = 1, num_procs_complete: int = 1, single: bool = True, log_level: str = 'info', raise_on_error: bool = False, connect_interactive: bool = False) → bool

start_processes() → str | None

start_supervisord(num_procs_transfer: int = 1, num_procs_complete: int = 1, single: bool = True, log_level: str = 'info', nodaemon: bool = False, connect_interactive: bool = False) → str | None

stop(wait: bool = False, raise_on_error: bool = False) → bool

wait_start(timeout: int = 30) → None

write_config(num_procs_transfer: int = 1, num_procs_complete: int = 1, single: bool = True, log_level: str = 'info', nodaemon: bool = False, connect_interactive: bool = False) → None

class jobflow_remote.jobs.daemon.DaemonStatus(value, names=None, *, module=None, qualname=None, type=None, start=1, boundary=None)

Bases: Enum

PARTIALLY_RUNNING = 'PARTIALLY_RUNNING'

RUNNING = 'RUNNING'

SHUT_DOWN = 'SHUT_DOWN'

STARTING = 'STARTING'

STOPPED = 'STOPPED'

STOPPING = 'STOPPING'