airflow

airflow copied to clipboard

Fix Mark Instance state buttons stay disabled if user lacks permission (#37451)

2

closes: #37451 This bug adresses a visual issue occuring when attempting to mark task states as Failed or Sucess, or when using clear button without the 'can edit on Task...

RodrigoGanancia

Clean up the exception handler when run_as_user is the airflow user

2

During the heartbeat check, the `local_task_job_runner` performs a check on the job's PID and raises an exception if it doesn't match what it expects. In the case that the job...

squingo44

Fix TaskHandlerWithCustomFormatter now adds prefix only once

3

When using the [TaskHandlerWithCustomFormatter](https://github.com/apache/airflow/blob/main/airflow/utils/log/task_handler_with_custom_formatter.py) to add a prefix to logs, it was previously adding the prefix multiple times. This happened because its `set_context` method was being called multiple times from...

TiDeane

Triggerer error "deque mutated during iteration"

2

### Apache Airflow version 2.8.1 ### If "Other Airflow 2 version" selected, which one? _No response_ ### What happened? When start more than 20 thousands trigger jobs, the triggerer may...

zhenghanyang

Scheduler fails to schedule DagRuns due to persistent DAG record lock

60

### Apache Airflow version Other Airflow 2 version (please specify below) ### If "Other Airflow 2 version" selected, which one? 2.7.3 ### What happened? We are encountering an issue in...

nookcreed

Title: Error When Using Multiple DataSets as Triggers in Apache AirFlow

3

### Apache Airflow version 2.8.0 ### If "Other Airflow 2 version" selected, which one? _No response_ ### What happened? When using two or more DataSets as triggers, an error occurs...

SoftDed

Dill fails to serialize context in Python 3.11 correctly

7

### Body There is a regression that needs investigation. One of our tests is failing only on Python 3.11 `tests/operators/test_python.py::TestPythonVirtualenvOperator::test_airflow_context` This test is part of PlainAssert suite and it has...

potiuk

Add deferrable_timeout to inntialize _timeout_sec of TaskStateTrigger

13

Use execution_timeout when inntializing _timeout_sec of TaskStateTrigger Previously, the state 'self._timeout_sec = 60' fixed timeout seconds to check if dag run exists. It caused timeout even if the dag run...

Xiroo

`dag.test()` never fails in Airflow 2.7.1

5

### Apache Airflow version 2.7.1 ### What happened I defined a task as a decorated function with `@task.kubernetes`. The function always fails. I want to test the DAG with `dag.test()`....

ketozhang

Deferrable ExternalTaskSensor cannot wait for an entire DAG

8

### Apache Airflow version 2.7.1 ### What happened When running an ExternalTaskSensor with `external_task_id=None` and in deferrable mode, the trigger doesn't wait for the entire DAG since it needs a...

ecodina