fixed merging issue

data-processing-lib/python/src/data_processing/test_support/transform/__init__.py

@@ -5,6 +5,11 @@
     NOOPTransformConfiguration,
     NOOPPythonTransformConfiguration
 )
+from data_processing.test_support.transform.noop_folder_transform import (
+    NOOPFolderTransform,
+    NOOPTransformConfiguration,
+    NOOPFolderPythonTransformConfiguration,
+)
 from data_processing.test_support.transform.resize_transform import (
     ResizeTransform,
     ResizePythonTransformConfiguration,

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_factory", None)
+        self.data_access_factory = config.get("data_access", 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")

data-processing-lib/ray/src/data_processing_ray/runtime/ray/transform_runtime.py

@@ -12,7 +12,7 @@
 
 from typing import Any
 
-from data_processing.data_access import DataAccessFactoryBase
+from data_processing.data_access import DataAccessFactoryBase, DataAccess
 from data_processing.transform import BaseTransformRuntime
 from ray.actor import ActorHandle
 

data-processing-lib/spark/src/data_processing_spark/runtime/spark/runtime_configuration.py

@@ -13,8 +13,7 @@
 from typing import Any
 
 from data_processing.data_access import DataAccessFactoryBase
-from data_processing.runtime import TransformRuntimeConfiguration
-from data_processing.transform import TransformConfiguration
+from data_processing.transform import TransformConfiguration, TransformRuntimeConfiguration
 from data_processing_spark.runtime.spark import DefaultSparkTransformRuntime
 
 
@@ -29,7 +28,7 @@ def __init__(
         :param transform_config - base configuration class
         :param runtime_class: implementation of the transform runtime
         """
-        super().__init__(transform_config=transform_config)
+        super().__init__(transform_config=transform_config, runtime_class=runtime_class)
         self.runtime_class = runtime_class
 
     def get_bcast_params(self, data_access_factory: DataAccessFactoryBase) -> dict[str, Any]:

data-processing-lib/spark/src/data_processing_spark/runtime/spark/transform_runtime.py

@@ -13,8 +13,7 @@
 from typing import Any
 
 from data_processing.data_access import DataAccessFactoryBase, DataAccess
-from data_processing.transform import TransformStatistics
-from data_processing.runtime import BaseTransformRuntime
+from data_processing.transform import BaseTransformRuntime, TransformStatistics
 
 
 class DefaultSparkTransformRuntime(BaseTransformRuntime):