airflow_supervisor.SupervisorSSH

class airflow_supervisor.SupervisorSSH(dag: DAG, cfg: SupervisorSSHAirflowConfiguration, host: Host = None, port: Port = None, **kwargs)[source]

Bases: Supervisor

__init__(dag: DAG, cfg: SupervisorSSHAirflowConfiguration, host: Host = None, port: Port = None, **kwargs)[source]

Methods

__init__(dag, cfg[, host, port])

get_base_operator_kwargs()

get_step_kwargs(step)

get_step_operator(step)

initialize_tasks()

setup_dag()

Attributes

check_programs

configure_supervisor

restart_programs

start_programs

start_supervisor

stop_programs

stop_supervisor

supervisor_client

unconfigure_supervisor