airflow
airflow copied to clipboard
Apache Airflow - A platform to programmatically author, schedule, and monitor workflows
This PR add [rowcounts](https://peps.python.org/pep-0249/#rowcount) to the output of the SQLExecuteQueryOperator. **Use-case**: The rowcount is already printed in the logs. It's a great info ! It's even better if this info...
--- Add retries to Job.heartbeat to avoid job SIGTERM due to intermittent/transient database issues. Raised in https://github.com/apache/airflow/discussions/37378
### Apache Airflow version Other Airflow 2 version (please specify below) ### What happened Version: 2.5.1 Run env: MWAA on AWS Summary: Once every ~500-1000 runs approximately, the task hangs...
Implement `batch_is_authorized_*` APIs in AWS auth manager --- **^ 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...
Time for `2.8.2rc1`!
Before, we had dataset events linked to a task instance or dag run below all of the details. It is too easy to miss that information, especially since those details...
This PR adds new operators to cover Describe and List Jobs functionality. --- **^ 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...
### Body Reproduce steps: Click on task duration view from the graph view when choosing specific task. I don't know if the expected behavior is to open the duration view...
this pull request is related to: https://github.com/apache/airflow-site/issues/945 the solution of "skipped" on the dag-loading when the virtualenv is not installed is wrap the dag loading with try-except and return None...
### Apache Airflow version Other Airflow 2 version (please specify below) ### If "Other Airflow 2 version" selected, which one? 2.7.1 ### What happened? I have airflow with statsd enabled...