File tree Expand file tree Collapse file tree 1 file changed +2
-1
lines changed
airflow-core/tests/unit/models Expand file tree Collapse file tree 1 file changed +2
-1
lines changed Original file line number Diff line number Diff line change @@ -2288,11 +2288,12 @@ def mapped_print_value(arg):
22882288 session .merge (ti )
22892289 dag_maker .run_ti ("generate_mapping_args" , dr )
22902290
2291- # Check if the correct number of new mapped task instances are created/ scheduled.
2291+ # Check if the new mapped task instances are correctly scheduled
22922292 decision = dr .task_instance_scheduling_decisions (session = session )
22932293 assert len (decision .schedulable_tis ) == rerun_length
22942294 assert all ([ti .task_id == "mapped_print_value" for ti in decision .schedulable_tis ])
22952295
2296+ # Check if mapped task rerun successfully
22962297 for ti in decision .schedulable_tis :
22972298 dag_maker .run_ti (ti .task_id , dr , map_index = ti .map_index )
22982299 query = select (TI ).filter_by (
You can’t perform that action at this time.
0 commit comments