Skip to content

Commit dc45c8b

Browse files
committed
PR Feedback 2
1 parent a62f6fc commit dc45c8b

File tree

3 files changed

+4
-6
lines changed

3 files changed

+4
-6
lines changed

sqlmesh/core/context.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -453,7 +453,7 @@ def snapshot_evaluator(self) -> SnapshotEvaluator:
453453
if not self._snapshot_evaluator:
454454
self._snapshot_evaluator = SnapshotEvaluator(
455455
{
456-
gateway: adapter.with_settings(log_level=logging.INFO)
456+
gateway: adapter.with_settings(execute_log_level=logging.INFO)
457457
for gateway, adapter in self.engine_adapters.items()
458458
},
459459
ddl_concurrent_tasks=self.concurrent_tasks,
@@ -1937,7 +1937,7 @@ def _table_diff(
19371937
)
19381938

19391939
return TableDiff(
1940-
adapter=adapter.with_settings(log_level=logger.getEffectiveLevel()),
1940+
adapter=adapter.with_settings(execute_log_level=logger.getEffectiveLevel()),
19411941
source=source,
19421942
target=target,
19431943
on=on,

sqlmesh/core/engine_adapter/base.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -153,7 +153,7 @@ def with_settings(self, **kwargs: t.Any) -> EngineAdapter:
153153
dialect=self.dialect,
154154
sql_gen_kwargs=self._sql_gen_kwargs,
155155
default_catalog=self._default_catalog,
156-
execute_log_level=kwargs.pop("log_level", self._execute_log_level),
156+
execute_log_level=kwargs.pop("execute_log_level", self._execute_log_level),
157157
register_comments=self._register_comments,
158158
null_connection=self._extra_config.pop("null_connection", True),
159159
multithreaded=self._multithreaded,

sqlmesh/core/snapshot/evaluator.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1190,9 +1190,7 @@ def _execute_create(
11901190
def set_correlation_id(self, correlation_id: CorrelationId) -> SnapshotEvaluator:
11911191
return SnapshotEvaluator(
11921192
{
1193-
gateway: adapter.with_settings(
1194-
log_level=adapter._execute_log_level, correlation_id=correlation_id
1195-
)
1193+
gateway: adapter.with_settings(correlation_id=correlation_id)
11961194
for gateway, adapter in self.adapters.items()
11971195
},
11981196
self.ddl_concurrent_tasks,

0 commit comments

Comments
 (0)