airflow

airflow copied to clipboard

Dynamic mapping over task group is broken with multiple_outputs

5

### Apache Airflow version main (development) ### If "Other Airflow 2 version" selected, which one? _No response_ ### What happened? When returning multiple outputs from a task and mapping task...

tanelk

smtp_default connection host/port is ignored when sending email

5

### Apache Airflow version Other Airflow 2 version (please specify below) ### If "Other Airflow 2 version" selected, which one? 2.5.1 ### What happened? Setup: AWS MWAA + `smtp_default` connection...

rogalski

Make ImapHook mail body encoding configurable

3

--- **Airflow IMAP Hook only decodes with UTF-8** I use the airflow imap hook, which internally only parses mail body with UTF-8 encoding. I have a mail with some German...

prutheus

Inlets not handled properly with @task functions

3

### Apache Airflow version Other Airflow 2 version (please specify below) ### If "Other Airflow 2 version" selected, which one? 2.8.0 ### What happened? A task with an outlet should...

ninowalker

`on_failure_callback` defined in `default_args` don't respect lists of callbacks

2

### Apache Airflow version Other Airflow 2 version (please specify below) ### If "Other Airflow 2 version" selected, which one? 2.7.3 ### What happened? I have a use case where...

ammarchalifah-bolt

Airflow 2.7.3: Mapped task group no longer works as expected

8

### Apache Airflow version 2.7.3 ### What happened Hello folks, I have a use case that doesn't work anymore after the release of the new version 2.7.3. I have done...

Ahmed-Khaled-CS

Tasks are stuck in running state. "select 1" query stuck in idle in transaction

2

### Apache Airflow version Other Airflow 2 version (please specify below) ### What happened Airflow version: 2.6.2, 2.7.1 Postgresql Version: 13.11 In our airflow setup, tasks are getting stuck in...

deepak4babu

Passing a DagRun to a PythonVirtualenvOperator gives NameError: name 'timedelta' is not defined

5

### Apache Airflow version 2.7.3 ### What happened I have a simple DAG (with render_template_as_native_obj option enabled). I'm trying to pass a {{ dag_run }} to a PythonVirtualenvOperator, but when...

Felix-neko

Allow jinja templating connection ids for all third party operators

2

### Description We use private staging and prod S3s(Ceph clusters for example) in our office. So there are often cases where DAGs are running with only connection ids changed. We...

kimminw00

Fix credentials error for S3ToGCSOperator trigger

1

closes: #37331 Add gcd_conn_id for S3ToGCSOperator trigger

korolkevich