in basic_pitch/data/pipeline.py [0:0]
def process(self, element: List[Any], *args: Tuple[Any, Any], **kwargs: Dict[str, Any]) -> Any:
for i in range(0, len(element), self.batch_size):
yield element[i : i + self.batch_size]