async def METHOD_NAME(
    asserting_events_worker: EventsWorker, reset_worker_events
):
    instance = InstrumentedClass()
    try:
        instance.sync_fail()
    except Exception:
        pass
    try:
        await instance.async_fail()
    except Exception:
        pass
    await asserting_events_worker.drain()
    assert isinstance(asserting_events_worker._client, AssertingEventsClient)
    assert len(asserting_events_worker._client.events) == 2
    sync_event = asserting_events_worker._client.events[0]
    assert sync_event.event == "prefect.instrumented.sync_fail.failed"
    assert sync_event.resource.id == "prefect.instrumented-class"
    assert sync_event.related[0].id == "prefect.class.InstrumentedClass"
    assert sync_event.related[0].role == "class"
    async_event = asserting_events_worker._client.events[1]
    assert async_event.event == "prefect.instrumented.async_fail.failed"
    assert async_event.resource.id == "prefect.instrumented-class"
    assert async_event.related[0].id == "prefect.class.InstrumentedClass"
    assert async_event.related[0].role == "class"