with dag_maker(session=session):
        @task
        def t(value, *, ti=None):
            results[(ti.task_id, ti.map_index)] = value
            return value
        @task_group
        def tg(va):