def execute(self, context):
            results.append(sorted(context["params"].items()))
    with dag_maker():
        PullOperator.partial(task_id="t", params=partial_params).expand(params=mapped_params)
    dr: DagRun = dag_maker.create_dagrun()
    decision = dr.task_instance_scheduling_decisions()
    for ti in decision.schedulable_tis:
        ti.run()
    assert sorted(results) == expected
def test_mapped_task_group_expands(dag_maker, session):