diff --git a/core/dbt/adapters/sql/connections.py b/core/dbt/adapters/sql/connections.py index 1f9fe35320b..826dc1c74c6 100644 --- a/core/dbt/adapters/sql/connections.py +++ b/core/dbt/adapters/sql/connections.py @@ -75,7 +75,8 @@ def add_query( fire_event( SQLQueryStatus( - status=self.get_response(cursor)._message, elapsed=round((time.time() - pre), 2) + status=self.get_response(cursor)._message, + elapsed=round((time.time() - pre), 2) ) ) diff --git a/core/dbt/events/types.py b/core/dbt/events/types.py index 8521c1226a9..19652695796 100644 --- a/core/dbt/events/types.py +++ b/core/dbt/events/types.py @@ -3,8 +3,8 @@ from dbt.events.stubs import ( _CachedRelation, BaseRelation, - ParsedModelNode, ParsedHookNode, + ParsedModelNode, _ReferenceKey, RunResult ) @@ -1928,7 +1928,7 @@ class PrintHookStartLine(InfoLevel, Cli, File, NodeInfo): index: int total: int truncate: bool - report_node_data: ParsedHookNode + report_node_data: Any # TODO: resolve ParsedHookNode circular import code: str = "Q032" def message(self) -> str: @@ -1948,7 +1948,7 @@ class PrintHookEndLine(InfoLevel, Cli, File, NodeInfo): total: int execution_time: int truncate: bool - report_node_data: ParsedHookNode + report_node_data: Any # TODO: resolve ParsedHookNode circular import code: str = "Q007" def message(self) -> str: diff --git a/core/dbt/task/run.py b/core/dbt/task/run.py index 41d58958b62..e9db0345c4c 100644 --- a/core/dbt/task/run.py +++ b/core/dbt/task/run.py @@ -364,8 +364,7 @@ def run_hooks(self, adapter, hook_type: RunHookType, extra_context): with Timer() as timer: if len(sql.strip()) > 0: - response, _ = adapter.execute(sql, auto_begin=False, - fetch=False) + response, _ = adapter.execute(sql, auto_begin=False, fetch=False) status = response._message else: status = 'OK'