airflow

airflow copied to clipboard

Grid, fix 404 taskInstance errors

2

~~We had a few warnings due to `validateDOMNesting` in the grid view (cf screenshot) -> split the table into two distinct tables with separate 'titles'. Took the opportunity to slightly...

pierrejeambrun

Migrate Amazon Provider Package's `SecretsManagerBackend`'s `full_url_mode=False` implementation.

1

# Objective I am following up on all the changes I've made in PR #25432 and which were originally discussed in issue #25104. The objective of the deprecations introduced in...

dwreeves

Dynamic task mapping zip() iterates unexpected number of times

7

### Apache Airflow version 2.4.0 ### What happened When running `zip()` with different-length lists, I get an unexpected result: ```python from datetime import datetime from airflow import DAG from airflow.decorators...

BasPH

This is useful for cases where we want to resolve an XCom without running a worker, e.g. to display the value in UI, logs, and OpenLineage. Since we don't want...

uranusjr

Enabling and Disabling the Task Before the DAG Run From UI and API

1

### Description Enabling and Disabling the task for the particular DAG from the UI and API. or using the parameter that disable it. This was it is easy to disable...

Amar1404

Reset executor_config when clearing a task?

1

### Body Currently if you clear a task, it won't clear the executor config. The executor config is pickled and added to the ti row at time of dag run...

dstandish

Have SLA docs reflect reality

3

### What do you see as an issue? The [SLA documentation](https://airflow.apache.org/docs/apache-airflow/stable/concepts/tasks.html#slas) currently states the following: > An SLA, or a Service Level Agreement, is an expectation for the maximum time...

notatallshaw-gts

Adding sensor decorator

21

Added the @task.sensor decorator to convert a Python function to an instance of the BaseSensorOperator. Example usage of the decorator is: ``` @task.sensor(poke_interval=60, timeout=3600, mode="poke") def f() -> PokeReturnValue: #...

mingshi-wang

Fix airflow tasks run --local when dags_folder differs from that of processor

1

Currently, if your dags_folder differs from that used by the dag processor, then task_run --local will fail to find the dag, because it uses the fileloc value stored in the...

dstandish

Better @task_group typing powered by ParamSpec and pre-commit

1

We can now type the decorator better than ever, even get rid of the fake type stub class. Some preparation work for task group expansion…

uranusjr