def METHOD_NAME(instance: DagsterInstance, empty_workspace_context):
    daemon = TestEventLogConsumerDaemon()
    list(daemon.run_iteration(empty_workspace_context))
    assert daemon.run_records == []
    run = create_run_for_test(instance, "test_job")
    instance.report_run_failed(run)
    list(daemon.run_iteration(empty_workspace_context))
    assert [record.dagster_run.run_id for record in daemon.run_records] == [run.run_id]
    # not called again for same event
    daemon.run_records = []  # reset this since it will keep the value from the last call
    list(daemon.run_iteration(empty_workspace_context))
    assert daemon.run_records == []