airflow
airflow copied to clipboard
apache
Apache Airflow - A platform to programmatically author, schedule, and monitor workflows
### Apache Airflow version 2.10.4 ### If "Other Airflow 2 version" selected, which one? Observed also on 2.10.2 ### What happened? One of the tests in our CI is creating...
### Apache Airflow version 2.5.2 ### What happened Users are experiencing the following: * A DAG begins to run * Task(s) go into running state, as expected * The DagRun...
### Description [Schedules](https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=311627076#AIP75NewAssetCentricSyntax-Schedules) This will probably be achieve by using `AssetRef` to access Asset by name This one could be deferred to "Data Completeness" ### Use case/motivation [Rationale](https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=311626828#AIP73ExpandedDataAwareness-Rationale) ### Related...
Allow the usage of the mypy plugins to typecheck the `@task` annotated tasks. With this change it will be possible to avoid mypy complains when definiing a task like in...
### Body We had some experiemental lineage classes in `airflow.lineage`. Those never caught on, and are not relevant anymore now that we have assets and trasparent OpenLineage support via [AIP-62](https://cwiki.apache.org/confluence/x/PoqSEQ)....
In this PR I have fixed `DataflowJobLink` in deferrable mode for `BeamRunPythonPipelineOperator` and `BeamRunJavaPipelineOperator` --- **^ 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...
### Official Helm Chart version 1.15.0 (latest released) ### Apache Airflow version 2.9.3 ### Kubernetes Version v1.26.15+4818370 ### Helm Chart configuration ``` securityContexts: { pod: { runAsUser: fsGroup: } }...
### Description [User Presentation Considerations](https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=311627076#AIP75NewAssetCentricSyntax-UserPresentationConsiderations) - [ ] `/public/assets` changes - [x] Use `id` as detail identifier in URL https://github.com/apache/airflow/pull/44801 - [ ] Ability to search asset with name and/or...
### Apache Airflow version 2.10.3 ### If "Other Airflow 2 version" selected, which one? _No response_ ### What happened? It seems like tasks created via `.expand()` do not inherit the...
### Apache Airflow version 2.7.0 ### What happened I have the following DAG: ```python from __future__ import annotations from datetime import datetime from airflow.decorators import dag, task, task_group from airflow.utils.trigger_rule...
