SameerMesiah97 commented on PR #68454:
URL: https://github.com/apache/airflow/pull/68454#issuecomment-4791015175
> Hi @kaxil , @amoghrajesh
>
> All checks are passing and the branch has been updated. Could you please
take a look at this PR? Thanks!
@bramhanandlingala
Can you run the following DAG using the code from `main` with and without
your fix and confirm that your fix is giving the intended result:
```
from datetime import datetime
from airflow import DAG
from airflow.operators.empty import EmptyOperator
from airflow.decorators import dag, task, task_group
from airflow.utils.trigger_rule import TriggerRule
@task
def get_the_list():
return ["one", "two", "three"]
@task
def process_something(x: str):
output = f"{x}"
print(output)
return output
@task_group
def the_task_group(x: str):
start = EmptyOperator(task_id="start")
something = process_something(x)
end = EmptyOperator(task_id="end")
start >> something >> end
@dag(
default_args={
"start_date": datetime(year=2025, month=12, day=1),
"trigger_rule": TriggerRule.NONE_FAILED_MIN_ONE_SUCCESS,
}
)
def dtm_bug_reproduce_dag_original_case():
end = EmptyOperator(task_id="end")
the_list = get_the_list()
mapped_group = (
the_task_group
.expand(x=the_list)
)
the_list >> mapped_group >> end
dag = dtm_bug_reproduce_dag_original_case()
```
--
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]
