Skip to content

Commit

Permalink
Fixed compeng cache key (#123)
Browse files Browse the repository at this point in the history
  • Loading branch information
altvod authored Nov 27, 2023
1 parent 75a5e06 commit d68bd16
Showing 1 changed file with 4 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand Down

0 comments on commit d68bd16

Please sign in to comment.