Skip to main content

Apache Airflow tools

Project description

Airflow Tools


Welcome to Airflow Tools! This package provides a collection of useful tools, utilities, and extensions for working with Apache Airflow, a platform to programmatically author, schedule, and monitor workflows.


  • Task Monitoring: Monitor task statuses and execution details easily.
  • Utilities: Helpful utility functions to simplify common Airflow tasks.
  • Extensions: Additional features and integrations to enhance your Airflow workflows.


You can install ch_airflow_tools using pip:

pip install ch_airflow_tools


Once installed, you can import and use the tools provided by this package in your Airflow DAGs and workflows. Here's a quick example of using the task monitoring feature:

from airflow import DAG
from airflow_tools.monitoring import get_task_status

default_args = {
    'owner': 'airflow',
    'depends_on_past': False,
    'start_date': datetime(2023, 8, 1),
    'retries': 1,

dag = DAG('example_dag', default_args=default_args, schedule_interval='@daily')

# Define your tasks here...

# Example of using the task monitoring function
task_status = get_task_status(dag=dag, task_id='my_task_id', execution_date='2023-08-22T00:00:00+00:00')
print("Task Status:", task_status)


Contributions are welcome! If you have an idea for a new feature, find a bug, or want to improve the documentation, feel free to open an issue or submit a pull request. Please make sure to follow the contribution guidelines when contributing.


This project is licensed under the Apache 2.0 License - see the LICENSE file for details.

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

ch_airflow_tools-4.1.tar.gz (6.9 kB view hashes)

Uploaded Source

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