Skip to main content

Airflow Supporter

Project description

airflow_supporter

airflow_supporter provide services to supporter to manage Apache Airflow

Usage

  1. 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]
        }
      
  2. 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()
    
  3. 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


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

airflow_supporter-1.0.0.tar.gz (4.5 kB view details)

Uploaded Source

Built Distribution

airflow_supporter-1.0.0-py3-none-any.whl (6.6 kB view details)

Uploaded Python 3

File details

Details for the file airflow_supporter-1.0.0.tar.gz.

File metadata

  • Download URL: airflow_supporter-1.0.0.tar.gz
  • Upload date:
  • Size: 4.5 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: poetry/1.5.1 CPython/3.9.17 Linux/5.15.0-1041-azure

File hashes

Hashes for airflow_supporter-1.0.0.tar.gz
Algorithm Hash digest
SHA256 232b79a24120b4fd5a102b533f8b0d2f5784805bd755f57108bc699887318827
MD5 7bb25ba3dd8c8ecbe911720df8203a1c
BLAKE2b-256 0c1a7c471ee6df4ab0744509389661b94feec5fca175d8c5a6ed0c9e6d04107f

See more details on using hashes here.

File details

Details for the file airflow_supporter-1.0.0-py3-none-any.whl.

File metadata

  • Download URL: airflow_supporter-1.0.0-py3-none-any.whl
  • Upload date:
  • Size: 6.6 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? No
  • Uploaded via: poetry/1.5.1 CPython/3.9.17 Linux/5.15.0-1041-azure

File hashes

Hashes for airflow_supporter-1.0.0-py3-none-any.whl
Algorithm Hash digest
SHA256 674473f7aba95c33a28b64ae97c3bc082dd4091fedaf30285394ce655ea3c53a
MD5 cbe6a7b2c635668de98e36a21443ebd5
BLAKE2b-256 79f97f11ab36656c60f849f188a35a478c940f0b369c83a9302b2b55a2787f35

See more details on using hashes here.

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page