async def METHOD_NAME(
    event_bus: EventBus,
    profile,
    event,
):
    """Test subscriber errors are logged but do not halt execution."""
    def _raise_exception(profile, event):
        raise Exception()
    processor = MockProcessor()
    bad_processor = _raise_exception
    event_bus.subscribe(re.compile(".*"), bad_processor)
    event_bus.subscribe(re.compile(".*"), processor)
    with async_mock.patch.object(
        test_module.LOGGER, "exception", async_mock.MagicMock()
    ) as mock_log_exc:
        await event_bus.notify(profile, event)
    assert mock_log_exc.called_once_with("Error occurred while processing event")
    assert processor.profile == profile
    assert processor.event == event