fix(joblib): update pipe function to use BATCHER instead of PIPE in H…

…yFI class

src/hyfi/main/__init__.py

@@ -25,7 +25,7 @@
 from hyfi.composer import Composer, DictKeyType, SpecialKeys
 from hyfi.composer.extended import XC
 from hyfi.dotenv import DotEnvConfig
-from hyfi.joblib import JobLibConfig
+from hyfi.joblib import JobLibConfig, BATCHER
 from hyfi.pipe import PIPE, PipeConfig
 from hyfi.project import ProjectConfig
 from hyfi.utils.datasets import DatasetLikeType, Datasets, DatasetType
@@ -374,8 +374,8 @@ def setLogger(level=None, force=True, **kwargs):
     # Batcher related functions
     ###############################
     @staticmethod
-    def pipe(data: Any, pipe_config: Union[Dict, PipeConfig]):
-        return PIPE.pipe(data, pipe_config)
+    def pipe(obj: Any, pipe_config: Union[Dict, PipeConfig]):
+        return PIPE.pipe(obj, pipe_config)
 
     @staticmethod
     def apply(
@@ -387,7 +387,7 @@ def apply(
         num_workers: Optional[int] = None,
         **kwargs,
     ):
-        return PIPE.apply(
+        return BATCHER.apply(
             func,
             series,
             description=description,