def METHOD_NAME(instance: DagsterInstance, empty_workspace_context):
    daemon = TestEventLogConsumerDaemon()
    list(daemon.run_iteration(empty_workspace_context))
    for _ in range(TEST_EVENT_LOG_FETCH_LIMIT + 1):
        run = create_run_for_test(instance, "test_job")
        instance.report_run_failed(run)
    list(daemon.run_iteration(empty_workspace_context))
    assert len(daemon.run_records) == TEST_EVENT_LOG_FETCH_LIMIT
    list(daemon.run_iteration(empty_workspace_context))
    assert len(daemon.run_records) == 1