fixed merging issue

data-processing-lib/python/src/data_processing/runtime/transform_file_processor.py

@@ -48,6 +48,7 @@ def __init__(
         # Add data access and statistics to the processor parameters
         self.transform_params = transform_parameters
         self.transform_params["data_access"] = self.data_access
+        self.transform_params["data_access_factory"] = data_access_factory
         self.is_folder = is_folder
 
     def process_file(self, f_name: str) -> None:

data-processing-lib/python/src/data_processing/transform/pipeline_transform.py

@@ -34,7 +34,7 @@ def __init__(self, config: dict[str, Any]):
             # Empty pipeline
             self.logger.error("Pipeline transform with empty list")
             raise UnrecoverableException("Pipeline transform with empty list")
-        self.data_access_factory = config.get("data_access", None)
+        self.data_access_factory = config.get("data_access_factory", None)
         if self.data_access_factory is None:
             self.logger.error("pipeline transform - Data access factory is not defined")
             raise UnrecoverableException("pipeline transform - Data access factory is not defined")

transforms/universal/ededup/python/src/ededup_transform_python.py

@@ -65,8 +65,6 @@ def __init__(self, params: dict[str, Any]):
         self.filter = None
         self.logger = get_logger(__name__)
 
-
-
     def get_transform_config(
         self, data_access_factory: DataAccessFactoryBase, statistics: TransformStatistics, files: list[str]
     ) -> dict[str, Any]: