diff --git a/dbt/adapters/bigquery/connections.py b/dbt/adapters/bigquery/connections.py index 63b7055ce..c7d8e382c 100644 --- a/dbt/adapters/bigquery/connections.py +++ b/dbt/adapters/bigquery/connections.py @@ -11,7 +11,7 @@ from functools import lru_cache import agate from requests.exceptions import ConnectionError -from typing import Optional, Any, Dict, List, Tuple +from typing import Optional, Any, Dict, Tuple import google.auth import google.auth.exceptions @@ -287,7 +287,7 @@ def exception_handler(self, sql): exc_message = exc_message.split(BQ_QUERY_JOB_SPLIT)[0].strip() raise DbtRuntimeError(exc_message) - def cancel_open(self) -> List[str]: + def cancel_open(self) -> None: names = [] this_connection = self.get_if_exists() with self.lock: @@ -308,7 +308,6 @@ def fn(): if connection.name is not None: names.append(connection.name) - return names @classmethod def close(cls, connection):