def METHOD_NAME():
    dag = get_dag()
    with instance_for_test() as instance:
        manager = instance.compute_log_manager
        # When mode is default and tags are set, run with tags
        job_def = make_dagster_job_from_airflow_dag(
            dag=dag,
            tags={AIRFLOW_EXECUTION_DATE_STR: EXECUTION_DATE_MINUS_WEEK_FMT},
        )
        result = job_def.execute_in_process(instance=instance)
        assert result.success
        for event in result.all_events:
            assert event.event_type_value != "STEP_FAILURE"
        check_captured_logs(manager, result, EXECUTION_DATE_MINUS_WEEK.strftime("%Y-%m-%d"))