Skip to content

Commit 0178d5e

Browse files
committed
PR Feedback 3
1 parent dc45c8b commit 0178d5e

File tree

2 files changed

+9
-4
lines changed

2 files changed

+9
-4
lines changed

sqlmesh/core/engine_adapter/base.py

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -148,18 +148,22 @@ def __init__(
148148
self.correlation_id = correlation_id
149149

150150
def with_settings(self, **kwargs: t.Any) -> EngineAdapter:
151+
extra_kwargs = {
152+
"null_connection": True,
153+
"execute_log_level": kwargs.pop("execute_log_level", self._execute_log_level),
154+
**self._extra_config,
155+
**kwargs,
156+
}
157+
151158
adapter = self.__class__(
152159
self._connection_pool,
153160
dialect=self.dialect,
154161
sql_gen_kwargs=self._sql_gen_kwargs,
155162
default_catalog=self._default_catalog,
156-
execute_log_level=kwargs.pop("execute_log_level", self._execute_log_level),
157163
register_comments=self._register_comments,
158-
null_connection=self._extra_config.pop("null_connection", True),
159164
multithreaded=self._multithreaded,
160165
pretty_sql=self._pretty_sql,
161-
**self._extra_config,
162-
**kwargs,
166+
**extra_kwargs,
163167
)
164168

165169
return adapter

sqlmesh/core/plan/evaluator.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -110,6 +110,7 @@ def evaluate(
110110
else:
111111
analytics.collector.on_plan_apply_end(plan_id=plan.plan_id)
112112
finally:
113+
self.snapshot_evaluator.recycle()
113114
self.console.stop_plan_evaluation()
114115

115116
def _evaluate_stages(

0 commit comments

Comments
 (0)