ds1 = DatasetModel(id=1, uri="one", extra={"foo": "bar"})
    ds2 = DatasetModel(id=2, uri="two")
    session.add_all([ds1, ds2])
    session.commit()
    
    dag, task1 = create_dummy_dag(
        dag_id="test_triggering_dataset_events",
        schedule=None,
        start_date=DEFAULT_DATE,
        task_id="test_context",
        with_dagrun_type=DagRunType.MANUAL,
        session=session,
    )
    dr = dag.create_dagrun(
        run_id="test2",
        run_type=DagRunType.DATASET_TRIGGERED,
        execution_date=timezone.utcnow(),
        state=None,
        session=session,
    )
    ds1_event = DatasetEvent(dataset_id=1)
    ds2_event_1 = DatasetEvent(dataset_id=2)