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`()
`set_downstream`(other)
`set_upstream`(other)
`setup_dag`()

Attributes

`check_programs`
`configure_supervisor`
`restart_programs`
`start_programs`
`start_supervisor`
`stop_programs`
`stop_supervisor`
`supervisor_client`
`unconfigure_supervisor`