airflow
airflow copied to clipboard
apache
Apache Airflow - A platform to programmatically author, schedule, and monitor workflows
Add the latest dag run to the returned dag in the public get `/dags` endpoint in fastapi. `dag.latest_dagrun` should be a serialized DagRun or None
In https://github.com/apache/airflow/pull/43015, a new Task Execution API-server was added. This can be run with the Core Airflow APIs and can also be run separately. To run all apis ```shell airflow...
Add get plugins to new AIP. Some types are `list[dict]` without more precision at this point (same as the legacy). ~~But I might explicit these types just in case the...
Those are draft diagrams showing Airflow Packaging for Airflow 2 and 3 --- **^ 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...
In order to create metrics in grafana for the edge worker, we want to use statsd to send the data to the prometheus database. Therefore we do this export in...
### Body https://github.com/apache/airflow/issues/42366 is taking care of migrating private endpoints. This issue focus on migrating all the public ones. Ideally they shouldn't change too much and be feature rich compare...
As part of [AIP-72](https://cwiki.apache.org/confluence/display/AIRFLOW/AIP-72+Task+Execution+Interface+aka+Task+SDK), we want to pass the Task Instance to the worker. Currently, the primary key of TI is a combination of `dag_id, task_id, run_id, map_index`. https://github.com/apache/airflow/blob/b4269f33c7151e6d61e07333003ec1e219285b07/airflow/models/taskinstance.py#L1815-L1819 Instead...
closes: #43130 --- **^ 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...
Better handling masking of values of set variable --- **^ 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...
Closes: https://github.com/apache/airflow/issues/42876 Related: https://github.com/apache/airflow/issues/42370 This migrates the Get DAG Source API from `api_connexion` to `api_fastapi`.
