FrankYang0529 opened a new pull request, #76886: URL: https://github.com/apache/airflow/pull/76886
Add e2e tests for task loops in `basic_tests/test_task_loops.py`, and add three new Dags for these tests in `dags/example_task_loop_test.py`: - `test_example_loop_runs_every_iteration`: the Dags in `example_task_loops.py` run all of their iterations, and every task in their loops succeeds in each iteration. - `test_task_outside_loop_reads_every_iteration`: a task outside the loop reads the results of all iterations. - `test_mapped_task_in_loop_expands_in_every_iteration`: a mapped task in a loop expands to 1, 2 and 3 task instances in iterations 1, 2 and 3. - `test_rerun_from_gate`: clearing the gate of iteration 2 through the REST API replaces iteration 3 in a new trajectory when `include_later_loop_iterations=True`, and keeps iteration 3 when `include_later_loop_iterations=False`. - `test_loop_that_never_meets_until_fails_the_run`: when `until` never returns True, the gate of the last iteration fails without retrying, and the Dag run fails. --- ##### Was generative AI tooling used to co-author this PR? <!-- If generative AI tooling has been used in the process of authoring this PR, please change below checkbox to `[X]` followed by the name of the tool, uncomment the "Generated-by". --> - [X] Yes - Claude Code <!-- Generated-by: [Tool Name] following [the guidelines](https://github.com/apache/airflow/blob/main/contributing-docs/05_pull_requests.rst#gen-ai-assisted-contributions) --> -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
