Skip to content

Commit 589b1f0

Browse files
committed
test fixes
1 parent b735f13 commit 589b1f0

1 file changed

Lines changed: 3 additions & 1 deletion

File tree

mindsdb_sql/planner/plan_join.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -481,6 +481,7 @@ def _check_conditions(node, **kwargs):
481481
conditions.append(node)
482482
elif table2 is not None:
483483
node.args = [arg1, arg2]
484+
node = copy.deepcopy(node)
484485
data_conditions.append(node)
485486

486487
query_traversal(fetch_table.join_condition, _check_conditions)
@@ -501,12 +502,13 @@ def _check_conditions(node, **kwargs):
501502

502503
# extract distinct values
503504
# remove alias
504-
arg2 = Identifier(parts=[arg2.parts[-1]])
505+
arg2.parts = arg2.parts[-1:]
505506
query2 = Select(targets=[arg2], distinct=True)
506507
subselect_step = SubSelectStep(query2, fetch_step.result)
507508
subselect_step = self.add_plan_step(subselect_step)
508509

509510
condition.args[1] = Parameter(subselect_step.result)
511+
condition.op = 'in'
510512
conditions.append(condition)
511513

512514
return conditions

0 commit comments

Comments
 (0)