airflow
airflow copied to clipboard
apache
Apache Airflow - A platform to programmatically author, schedule, and monitor workflows
--- Closes: https://github.com/apache/airflow/issues/33818 ## What? * Adds optional support for "trigger queues", which allows a given triggerer to consume from a user-configured subset of triggers. * Adds a `trigger_queues` instance...
### Apache Airflow version 3.0.4 ### If "Other Airflow 2 version" selected, which one? _No response_ ### What happened? After upgrading our Airflow deployment from version 3.0.3 to 3.0.4, all...
This PR improves the unit-testing section of the Airflow documentation by adding runnable pytest examples for testing custom operators. The existing docs show a dag.test() example which behaves differently inside...
This PR is related to the discussion I started on the [devlist](https://lists.apache.org/thread/ztnfsqolow4v1zsv4pkpnxc1fk0hbf2p) and which allows you to natively execute async code on PythonOperators. There is also an AIP for this:...
### Apache Airflow version main (development) ### If "Other Airflow 2/3 version" selected, which one? _No response_ ### What happened? When DAGs that previously outlet/scheduled by Assets are added to...
--- **^ Add meaningful description above** Read the **[Pull Request Guidelines](https://github.com/apache/airflow/blob/main/contributing-docs/05_pull_requests.rst#pull-request-guidelines)** for more information. In case of fundamental code changes, an Airflow Improvement Proposal ([AIP](https://cwiki.apache.org/confluence/display/AIRFLOW/Airflow+Improvement+Proposals)) is needed. In case of...
### Apache Airflow version Other Airflow 2/3 version (please specify below) ### If "Other Airflow 2/3 version" selected, which one? 3.1.4 ### What happened? Description : The Dag Processor correctly...
## Description This PR addresses issue #53826. Currently, the Pool Bar visually includes `Scheduled` and `Deferred` states inside the progress bar. This can be misleading as these states do not...
There is a chance of a transient error inside the Kubernetes provider when two identical pods are spawned but the pod.status.start_time parameter is not set yet. To prevent this situation,...
