airflow_systemd.SystemdSSH¶

class airflow_systemd.SystemdSSH(dag: DAG, cfg: SystemdSSHAirflowConfiguration | dict, host: Host | dict | None = None, **kwargs: Any)[source]¶

Airflow task group for a systemd job managed over SSH.

__init__(dag: DAG, cfg: SystemdSSHAirflowConfiguration | dict, host: Host | dict | None = None, **kwargs: Any)[source]¶

Methods

`__init__`(dag, cfg[, host])
`get_base_operator_kwargs`()
`get_step_kwargs`(step)
`get_step_operator`(step)
`initialize_tasks`()
`set_downstream`(other)
`set_upstream`(other)
`setup_dag`()
`update_relative`(other[, upstream, edge_modifier])

Attributes