Unable to retrieve logs for nested task group when parent is mapped #34535
Description
Apache Airflow version
2.7.1
What happened
Unable to retrieve logs for task inside task group inside mapped task group.
Got 404 "TaskInstance not found" in network requests
What you think should happen instead
No response
How to reproduce
from datetime import datetime
from airflow import DAG
from airflow.decorators import task, task_group
from airflow.operators.bash import BashOperator
from airflow.utils.task_group import TaskGroup
with DAG("mapped_task_group_bug", schedule=None, start_date=datetime(1970, 1, 1)):
@task
def foo():
return ["a", "b", "c"]
@task_group
def bar(x):
with TaskGroup("baz"):
# If child task group exists, logs 404
# "TaskInstance not found"
# http://localhost:8080/api/v1/dags/mapped_task_group_bug/dagRuns/manual__2023-09-21T22:31:56.863704+00:00/taskInstances/bar.baz.bop/logs/2?full_content=false
# if it is removed, logs appear
BashOperator(task_id="bop", bash_command="echo hi $x", env={"x": x})
bar.partial().expand(x=foo())
Operating System
debian 11 / astro dev start
Versions of Apache Airflow Providers
No response
Deployment
Astronomer
Deployment details
No response
Anything else
No response
Are you willing to submit PR?
- Yes I am willing to submit a PR!
Code of Conduct
- I agree to follow this project's Code of Conduct