async def METHOD_NAME(self, event: CloudEvent) -> None:
    if not self._running:
        raise asyncio.InvalidStateError(
            "trying to handle event after batcher is done"
        )
    function = self._LOOKUP_MAP[event["type"]]
    with self._buffer_lock:
        self._buffer.append((function, event))