print(x)
    with dag_maker() as dag:
        printx.expand(x=[1])
    dr1: DagRun = dag_maker.create_dagrun(run_type=DagRunType.SCHEDULED)
    ti = dr1.get_task_instances()[0]
    
    
    ti.map_index = -1
    session.merge(ti)
    session.flush()
    
    
    session.add(TaskFail(ti))
    XCom.set(key="test", value="value", task_id=ti.task_id, dag_id=dag.dag_id, run_id=ti.run_id)
    session.commit()
    for table in [TaskFail, XCom]:
        assert session.query(table).count() == 1
    dr1.task_instance_scheduling_decisions(session)
    for table in [TaskFail, XCom]:
        assert session.query(table).count() == 0
def test_dagrun_with_note(dag_maker, session):