From d68bd1668c928a83399d486adcb73100e5d1c6cc Mon Sep 17 00:00:00 2001 From: Grigory Statsenko Date: Mon, 27 Nov 2023 14:46:43 +0100 Subject: [PATCH] Fixed compeng cache key (#123) --- .../data_processing/processing/db_base/op_executors.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) 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 dabab35c3..e36c2b8d8 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 @@ -187,7 +187,10 @@ def make_data_key(self, op: BaseOp) -> LocalKeyRepresentation: query_compiler = from_info.query_compiler query = query_compiler.compile_select( bi_query=op.bi_query, - sql_source=from_info.sql_source, + # The info about the real source is already contained in the previous key parts, + # and, also, we want to avoid the randomized table names (in compeng) to appear in the key. + # So just use a fake table here. + sql_source=sa.table("table"), ) legacy_data_key = self.db_ex_adapter.get_data_key( query=query,