airflow-supporter 1.0.0

Description:

airflowsupporter 1.0.0

airflow_supporter
airflow_supporter provide services to supporter to manage Apache Airflow
Usage


Alert email on off DAG and turn on DAG automatically


Insert following example in your DAG
from airflow_supporter.dag.check_off_dag import create_check_off_dag
create_check_off_dag()



Variable

enroll following Variable in your airflow
check_off_dag_variable

{
exclude_dag_list: list[str], default empty list,
automatically_turn_on: bool, default true,
email: Optional[str]
}





Restart failed DagRun
@dag(dag_id="restart_failed_dagrun_dag", schedule="* * * * *", is_paused_upon_creation=False, catchup=False,
start_date=datetime(year=1970, month=1, day=1), )
def restart_failed_dagrun_dag() -> None:
restart_failed_dagrun_op.restart_failed_dagrun_op(rv=RestartFailedDagrunVariable())

restart_failed_dagrun_dag()



Restart stucked Task
@dag(dag_id="clear_stucked_task_dag", schedule="* * * * *", is_paused_upon_creation=False, catchup=False,
start_date=datetime(year=1970, month=1, day=1), )
def clear_stucked_task_dag() -> None:
restart_stucked_task_op.clear_stucked_task_op(rv=RestartStuckedTaskVariable())

clear_stucked_task_dag()