diff --git a/dbt/adapters/bigquery/gcloud.py b/dbt/adapters/bigquery/gcloud.py index 77ed74fdc..fed379cbe 100644 --- a/dbt/adapters/bigquery/gcloud.py +++ b/dbt/adapters/bigquery/gcloud.py @@ -1,4 +1,4 @@ -from dbt.logger import GLOBAL_LOGGER as logger +from dbt.events import AdapterLogger import dbt.exceptions from dbt.clients.system import run_cmd @@ -9,6 +9,8 @@ https://cloud.google.com/sdk/ """ +logger = AdapterLogger("Bigquery") + def gcloud_installed(): try: diff --git a/dbt/adapters/bigquery/impl.py b/dbt/adapters/bigquery/impl.py index f828c37f8..a3bea2b97 100644 --- a/dbt/adapters/bigquery/impl.py +++ b/dbt/adapters/bigquery/impl.py @@ -14,7 +14,8 @@ from dbt.adapters.bigquery import BigQueryColumn from dbt.adapters.bigquery import BigQueryConnectionManager from dbt.contracts.graph.manifest import Manifest -from dbt.logger import GLOBAL_LOGGER as logger, print_timestamped_line +from dbt.logger import print_timestamped_line +from dbt.events import AdapterLogger from dbt.utils import filter_null_values import google.auth @@ -29,6 +30,8 @@ import agate import json +logger = AdapterLogger("Bigquery") + # Write dispositions for bigquery. WRITE_APPEND = google.cloud.bigquery.job.WriteDisposition.WRITE_APPEND WRITE_TRUNCATE = google.cloud.bigquery.job.WriteDisposition.WRITE_TRUNCATE diff --git a/tests/integration/base.py b/tests/integration/base.py index 6e31d2d71..9d43c3a11 100644 --- a/tests/integration/base.py +++ b/tests/integration/base.py @@ -22,10 +22,12 @@ from dbt.clients.jinja import template_cache from dbt.config import RuntimeConfig from dbt.context import providers -from dbt.logger import GLOBAL_LOGGER as logger, log_manager +from dbt.logger import log_manager +from dbt.events import AdapterLogger from dbt.contracts.graph.manifest import Manifest +logger = AdapterLogger("Bigquery") INITIAL_ROOT = os.getcwd()