MaiHoangViet1809 opened a new issue, #30276:
URL: https://github.com/apache/airflow/issues/30276
### Apache Airflow version
Other Airflow 2 version (please specify below)
### What happened
When trying dynamic task_group mapping, it work, but current UI did not show
each task_group index nor child task log.
### What you think should happen instead
Current airflow UI did not cover this case.
### How to reproduce
```
from airflow.decorators import dag, task_group, task
from pendulum import datetime
@dag(dag_id="test_task_group",
start_date=datetime(2022, 12, 1),
schedule=None,
catchup=False,
)
def task_group_mapping_example():
# creating a task group using the decorator with the dynamic input my_num
@task_group(group_id="group1")
def tg1(my_num):
@task
def print_num(num):
return num
@task
def add_42(num):
return num + 42
return add_42(print_num(my_num))
# a downstream task to print out resulting XComs
@task
def pull_xcom(data):
print(data)
# creating 6 mapped task group instances of the task group group1 (2.5
feature)
tg1_object = tg1.expand(my_num=[19, 23, 42, 8, 7, 108])
# setting dependencies
pull_xcom(tg1_object)
task_group_mapping_example()
```
### Operating System
docker
### Versions of Apache Airflow Providers
_No response_
### Deployment
Docker-Compose
### Deployment details
Custom Airflow docker composer using dask executor
### Anything else
_No response_
### Are you willing to submit PR?
- [ ] Yes I am willing to submit a PR!
### Code of Conduct
- [X] I agree to follow this project's [Code of
Conduct](https://github.com/apache/airflow/blob/main/CODE_OF_CONDUCT.md)
--
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]
