def METHOD_NAME(instance: DagsterInstance, postgres_airflow_db: str) -> None:
    with tempfile.TemporaryDirectory() as dags_path:
        with open(os.path.join(dags_path, "dag.py"), "wb") as f:
            f.write(bytes(RETRY_DAG.encode("utf-8")))
        utc_date_string = "2023-02-01T00:00:00+00:00"
        reconstructable_job = build_reconstructable_job(
            reconstructor_module_name="test_persistent_airflow_db",
            reconstructor_function_name="reconstruct_retry_job",
            reconstructor_working_directory=os.path.dirname(os.path.realpath(__file__)),
            reconstructable_kwargs={
                "postgres_airflow_db": postgres_airflow_db,
                "dags_path": dags_path,
            },
        )
        # Initial execution
        initial_result = execute_job(
            job=reconstructable_job,
            instance=instance,
            tags={"airflow_execution_date": utc_date_string},
        )
        assert not initial_result.success
        options = ReexecutionOptions.from_failure(initial_result.run_id, instance)
        from_failure_result = execute_job(
            job=reconstructable_job,
            instance=instance,
            reexecution_options=options,
            tags={"airflow_execution_date": utc_date_string},
        )
        assert from_failure_result.success