Airflow Supporter
Project description
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()
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Close
Hashes for airflow_supporter-1.0.0-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 674473f7aba95c33a28b64ae97c3bc082dd4091fedaf30285394ce655ea3c53a |
|
MD5 | cbe6a7b2c635668de98e36a21443ebd5 |
|
BLAKE2b-256 | 79f97f11ab36656c60f849f188a35a478c940f0b369c83a9302b2b55a2787f35 |