def METHOD_NAME(self) -> None:
    """Set all events and reset the batch queue."""
    self._requests: List[DataRequest] = []
    self._request_lens: List[int] = []
    if not docarray_v2:
        self._big_doc: DocumentArray = DocumentArray.empty()
    else:
        self._big_doc = self._docarray_cls()
    self._flush_trigger: Event = Event()
    self._flush_task: Optional[Task] = None
    self._timer_task: Optional[Task] = None