ephraimbuddy commented on PR #36462:
URL: https://github.com/apache/airflow/pull/36462#issuecomment-2015546025
Can you add this test:
```
def
test_mapped_tasks_in_mapped_task_group_waits_for_upstreams_to_complete(dag_maker,
session):
"""Test that one failed trigger rule works well in mapped task group"""
with dag_maker() as dag:
@dag.task
def t1():
return [1, 2, 3]
@task_group("tg1")
def tg1(a):
@dag.task()
def t2(a):
return a
@dag.task(trigger_rule=TriggerRule.ONE_FAILED)
def t3(a):
return a
t2(a) >> t3(a)
t = t1()
tg1.expand(a=t)
dr = dag_maker.create_dagrun()
ti = dr.get_task_instance(task_id="t1")
ti.run()
dr.task_instance_scheduling_decisions()
ti3 = dr.get_task_instance(task_id="tg1.t3")
assert not ti3.state
```
--
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: commits-unsubscr...@airflow.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
