kacpermuda commented on code in PR #75132:
URL: https://github.com/apache/airflow/pull/75132#discussion_r4323837116
##########
airflow-core/tests/unit/api_fastapi/execution_api/versions/head/test_task_instances.py:
##########
@@ -657,14 +657,67 @@ def body():
assert response.status_code == 200
if version == "2026-06-30":
assert "loop" not in response.json()
+ assert "expanded_ti_count" not in response.json()
return
assert response.json()["loop"] == {
"node_id": loop.group_id,
"index": 2,
"max_iterations": 4,
"terminal_task_id": loop.terminal_task_id,
"terminal_is_mapped": mapped,
+ "region_id": str(parent.id),
+ "trajectory": 1,
+ "forked_from_region_id": None,
+ "resumes_from_index": 0,
Review Comment:
Done: forked_from_region_id and resumes_from_index are only set for a fork,
so the response leaves them out for the original region.
##########
airflow-core/tests/unit/api_fastapi/execution_api/versions/head/test_task_instances.py:
##########
@@ -657,14 +657,67 @@ def body():
assert response.status_code == 200
if version == "2026-06-30":
assert "loop" not in response.json()
+ assert "expanded_ti_count" not in response.json()
return
assert response.json()["loop"] == {
"node_id": loop.group_id,
"index": 2,
"max_iterations": 4,
"terminal_task_id": loop.terminal_task_id,
"terminal_is_mapped": mapped,
+ "region_id": str(parent.id),
+ "trajectory": 1,
+ "forked_from_region_id": None,
+ "resumes_from_index": 0,
Review Comment:
Yes, resumes_from_index is None for the original region now (and absent from
the response).
--
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]
