This is an automated email from the ASF dual-hosted git repository.
ashb pushed a change to branch task-loops-stack-8
in repository https://gitbox.apache.org/repos/asf/airflow.git
discard 771b718ac20 Clear selected loop work and regenerate only what was
replaced
discard 8f2f3b2e806 Run loop gates and advance iterations atomically
discard 0f448fbca46 Attribute log, asset-event and asset-state writes to the
task attempt
discard 9f0a1c6c8cd Give every mapped expansion a region and store its index
as region_index
discard b93e57de45c Pin loop definitions and carry region coordinates through
task execution
discard b419bdadece Resolve live producers by region and read their XCom by
attempt
discard e1d3269423b Introduce the (internal/db level) concept of "dynamic
regions" for TIs
discard 23eaa0219a1 Add user-facing docs for the new Task Loops feature.
add 919765f3cf7 Rename the max_active_runs recompute test and drop a no-op
mock (#74483)
add 1f5331de1fa Document the experimental Dag importer interface (#74333)
add 8e14de67e3f Fix `KubernetesExecutor` leaving invalid-config tasks
stuck in queued (#74512)
add 07a0c4da099 Fix TypeError clearing a DAG run when a queued-at deadline
interval is stored as JSON (#70370)
add df7b8a7d4ca Bump the auth-ui-package-updates group across 1 directory
with 2 updates (#74507)
add 466e847d3de Add routable to docs spelling wordlist (#74526)
add dd9cac49d1a Add user-facing docs for the new Task Loops feature.
add cdda9db06f0 Introduce the (internal/db level) concept of "dynamic
regions" for TIs
add 2dda9b4c472 Resolve live producers by region and read their XCom by
attempt
add 9ec232bebed Pin loop definitions and carry region coordinates through
task execution
add fc3aa41b7d1 fixup! Pin loop definitions and carry region coordinates
through task execution
add db43361222c Give every mapped expansion a region and store its index
as region_index
add 930f347f647 fixup! Give every mapped expansion a region and store its
index as region_index
add 094f4b6d8af Attribute log, asset-event and asset-state writes to the
task attempt
add 867cbd55ce8 Run loop gates and advance iterations atomically
add c8347245609 fixup! Run loop gates and advance iterations atomically
add 840e9e52ff2 Clear selected loop work and regenerate only what was
replaced
add df15219903a fixup! Clear selected loop work and regenerate only what
was replaced
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (771b718ac20)
\
N -- N -- N refs/heads/task-loops-stack-8 (df15219903a)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.../dag-importers.rst | 169 +++++++++++++++++++
.../dagfile-processing.rst | 10 +-
.../docs/administration-and-deployment/index.rst | 1 +
airflow-core/docs/core-concepts/dags.rst | 4 +-
airflow-core/docs/public-airflow-interface.rst | 16 ++
.../auth/managers/simple/ui/package.json | 4 +-
.../auth/managers/simple/ui/pnpm-lock.yaml | 176 ++++++++++----------
.../core_api/services/public/task_coordinates.py | 6 +-
.../core_api/services/public/task_instances.py | 31 +---
.../execution_api/routes/task_instances.py | 13 +-
.../src/airflow/executors/workloads/task.py | 7 +-
.../src/airflow/jobs/scheduler_job_runner.py | 1 +
.../src/airflow/jobs/triggerer_job_runner.py | 1 +
airflow-core/src/airflow/models/dagrun.py | 49 +++++-
.../src/airflow/models/task_coordinates.py | 13 ++
airflow-core/src/airflow/models/taskinstance.py | 78 ++++++---
airflow-core/src/airflow/serialization/decoders.py | 44 ++++-
.../src/airflow/serialization/definitions/dag.py | 26 +--
.../src/airflow/utils/log/task_log_address.py | 26 +--
.../core_api/routes/public/test_task_instances.py | 5 +-
.../versions/head/test_task_instances.py | 29 ++++
.../tests/unit/executors/test_workloads.py | 17 +-
airflow-core/tests/unit/jobs/test_scheduler_job.py | 26 +--
airflow-core/tests/unit/models/test_cleartasks.py | 27 +++
airflow-core/tests/unit/models/test_dagrun.py | 77 ++++++++-
.../tests/unit/models/test_taskinstance.py | 182 +++++++++++++++++++--
.../tests/unit/serialization/test_decoders.py | 84 ++++++++++
docs/spelling_wordlist.txt | 1 +
.../kubernetes/executors/kubernetes_executor.py | 3 +-
.../executors/test_kubernetes_executor.py | 40 +++++
task-sdk/docs/api.rst | 35 ++++
.../src/airflow/sdk/definitions/_internal/loop.py | 34 ++++
task-sdk/src/airflow/sdk/definitions/dag.py | 4 +
task-sdk/tests/task_sdk/definitions/test_dag.py | 66 ++++++++
34 files changed, 1072 insertions(+), 233 deletions(-)
create mode 100644
airflow-core/docs/administration-and-deployment/dag-importers.rst
create mode 100644 airflow-core/tests/unit/serialization/test_decoders.py
