def METHOD_NAME(self):
    if self._batching_task is not None:
        if not self._batching_task.done():
            # If task hasn't finished yet, let it keep running
            return
    self._batching_task = schedule_with_callback(
        self._batcher(), self._batching_task_callback
    )