diff --git a/lib/dl_core/dl_core/data_processing/processing/db_base/op_executors.py b/lib/dl_core/dl_core/data_processing/processing/db_base/op_executors.py
index 4a34c71c3..b11321c9e 100644
--- a/lib/dl_core/dl_core/data_processing/processing/db_base/op_executors.py
+++ b/lib/dl_core/dl_core/data_processing/processing/db_base/op_executors.py
@@ -201,7 +201,7 @@ def make_data_key(self, op: BaseOp) -> LocalKeyRepresentation:
             f"new key: {new_data_key.key_parts_hash}"
         )
 
-        return legacy_data_key
+        return new_data_key
 
     @log_op  # type: ignore  # TODO: fix
     async def execute(self, op: BaseOp) -> DataSourceVS:  # type: ignore  # TODO: fix