diff --git a/src/dimcat/steps/pipelines/base.py b/src/dimcat/steps/pipelines/base.py
index eba7b859..e6ad8390 100644
--- a/src/dimcat/steps/pipelines/base.py
+++ b/src/dimcat/steps/pipelines/base.py
@@ -113,7 +113,7 @@ def _process_resource(
         for step in pipeline_steps:
             previous_resource = processed_resource
             try:
-                processed_resource = step._process_resource(previous_resource)
+                processed_resource = step.process_resource(previous_resource)
             except Exception as e:
                 if ignore_exceptions:
                     self.logger.info(