This is an automated email from the ASF dual-hosted git repository.
ashb pushed a change to branch task-loops-stack-10
in repository https://gitbox.apache.org/repos/asf/airflow.git
omit 3d8e2a3fb47 Let the HITL review plugin address one loop pass or mapped
slot
omit 6adc19655bc fixup! Read current task executions by exact region and try
omit 178c5505960 fixup! Read current task executions by exact region and try
omit 49e318ebbc7 Read current task executions by exact region and try
omit df15219903a fixup! Clear selected loop work and regenerate only what
was replaced
omit 840e9e52ff2 Clear selected loop work and regenerate only what was
replaced
omit c8347245609 fixup! Run loop gates and advance iterations atomically
omit 867cbd55ce8 Run loop gates and advance iterations atomically
omit 094f4b6d8af Attribute log, asset-event and asset-state writes to the
task attempt
add d6b888d3caa fixup! Give every mapped expansion a region and store its
index as region_index
add 30857fbf9f3 fixup! Give every mapped expansion a region and store its
index as region_index
add dc2db0661fc Attribute log, asset-event and asset-state writes to the
task attempt
add 51cc1f74aaa fixup! Attribute log, asset-event and asset-state writes
to the task attempt
add 3285b99bd3d Run loop gates and advance iterations atomically
add b552696f20a fixup! Run loop gates and advance iterations atomically
add a6212a749fc Clear selected loop work and regenerate only what was
replaced
add 13d2fb62154 fixup! Clear selected loop work and regenerate only what
was replaced
add 9106653f34f Read current task executions by exact region and try
add f3ab4ee5538 fixup! Read current task executions by exact region and try
add 90bb554e5d4 fixup! Read current task executions by exact region and try
add 18c91d556f1 Let the HITL review plugin address one loop pass or mapped
slot
add d3e9ff064c5 fixup! Let the HITL review plugin address one loop pass or
mapped slot
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 (3d8e2a3fb47)
\
N -- N -- N refs/heads/task-loops-stack-10 (d3e9ff064c5)
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:
airflow-core/src/airflow/models/dynamic_region.py | 2 +
airflow-core/tests/unit/models/test_dagrun.py | 11 +-
.../providers/common/ai/plugins/hitl_review.py | 4 +-
.../unit/common/ai/plugins/test_hitl_review.py | 2 +-
.../providers/openlineage/plugins/listener.py | 21 ++-
.../airflow/providers/openlineage/utils/utils.py | 161 +++++++++++++++------
.../unit/openlineage/plugins/test_listener.py | 17 ++-
.../tests/unit/openlineage/plugins/test_macros.py | 12 ++
.../tests/unit/openlineage/utils/test_utils.py | 95 +++++++++---
9 files changed, 238 insertions(+), 87 deletions(-)
