airflow

airflow copied to clipboard

Decorator for Task Flow (@skip_if, @run_if) to make it simple to apply whether or not to skip a Task -> Implementation also for Task Groups

3

### Description It would be really helpful, if the new feature @skip_if and @run_if would be available also for whole TaskGroups. With that I would be able to easily toggle...

weidinger-c

WIP - Bugfix/edge worker pid file

1

# Summary This is a PR draft, which not finished yet

OliverWannenwetsch

Publish JSON schema for airflow.cfg

16

### Description There is already a good structured YAML file providing metadata about all valid configuration options in `airflow.cfg`: [airflow/config_templates/config.yml](https://github.com/apache/airflow/blob/9c4b81d71f3caee3a3b1c6d9c626ee5d16f0db7c/airflow/config_templates/config.yml). I think publishing the same data as a JSON schema...

ghjklw

Add additional named parameters and job parameters support to DatabricksRunNowOperator

1

- Changes - Added additional named parameters support to `DatabricksRunNowOperator`: - `dbt_commands` - `job_parameters` - How is it tested - Updated the tests to check the new changes --- **^...

pranshupand-db

Close: https://github.com/apache/airflow/issues/42312 --- **^ 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...

Lee-W

### Apache Airflow version 2.10.2 ### If "Other Airflow 2 version" selected, which one? _No response_ ### What happened? We are using custom plugin with listener on_dag_run_running. That is being...

BretaGlac

Inconsistent display of timezone

1

### Apache Airflow version 2.10.2 ### If "Other Airflow 2 version" selected, which one? _No response_ ### What happened? ### What you think should happen instead? The Timezone displayed in...

hydeboy

Implemented StreamedOperator

6

As proposed on the [devlist](https://lists.apache.org/thread/bx2w6dpr3ynvnq06n4v62n7g8dodt2rt) I've implemented a new oprator called the "StreamedOperator". Of course I don't know if this is a good name, but I'll explain what I wanted...

dabla

Introduce notion of dialects in DbApiHook

23

This PR introduces the notion of an SQL Dialect class in the DbApiHook. Let me first elaborate why I did such an approach, this PR is a proposition and can...

dabla

Fix instruction for docker compose(tested on Mac M1)

2

Make fixes that allows to run airflow dags in pycharm debugger on Mac M1 --- **^ 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...

Udbv