convert to use struct logging for adapters

dbt/adapters/spark/connections.py

@@ -4,7 +4,7 @@
 from dbt.adapters.base import Credentials
 from dbt.adapters.sql import SQLConnectionManager
 from dbt.contracts.connection import ConnectionState
-from dbt.logger import GLOBAL_LOGGER as logger
+from dbt.events import AdapterLogger
 from dbt.utils import DECIMALS
 from dbt.adapters.spark import __version__
 
@@ -42,6 +42,8 @@
 import base64
 import time
 
+logger = AdapterLogger("Spark")
+
 NUMBERS = DECIMALS + (int, float)
 
 

dbt/adapters/spark/impl.py

@@ -16,9 +16,11 @@
 from dbt.adapters.spark import SparkColumn
 from dbt.adapters.base import BaseRelation
 from dbt.clients.agate_helper import DEFAULT_TYPE_TESTER
-from dbt.logger import GLOBAL_LOGGER as logger
+from dbt.events import AdapterLogger
 from dbt.utils import executor
 
+logger = AdapterLogger("Spark")
+
 GET_COLUMNS_IN_RELATION_MACRO_NAME = 'get_columns_in_relation'
 LIST_SCHEMAS_MACRO_NAME = 'list_schemas'
 LIST_RELATIONS_MACRO_NAME = 'list_relations_without_caching'

tests/integration/base.py

@@ -23,9 +23,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("Spark")
+
 INITIAL_ROOT = os.getcwd()