async def METHOD_NAME(
    event_filter: EventFilter,
    port_key_1: str,
    mocked_port_key_content_changed: AsyncMock,
):
    # event triggers once
    await event_filter.enqueue(port_key_1)
    await _wait_for_event_to_trigger(event_filter)
    assert mocked_port_key_content_changed.call_count == 1
    # event triggers a second time
    await event_filter.enqueue(port_key_1)
    await _wait_for_event_to_trigger(event_filter)
    assert mocked_port_key_content_changed.call_count == 2