revert session URL hardcoring, add comments

dbt-labs · Oct 1, 2023 · bebcee1 · bebcee1
1 parent c63af4e
commit bebcee1
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/dbt/adapters/spark/connections.py b/dbt/adapters/spark/connections.py
@@ -536,10 +536,11 @@ def open(cls, connection: Connection) -> Connection:
                         SessionConnectionWrapper,
                     )
 
+                    # Pass session type (session or connect) into SessionConnectionWrapper
                     handle = SessionConnectionWrapper(
                         Connection(
                             conn_method=creds.method,
-                            conn_url="localhost",
+                            conn_url=conn_url,
                             server_side_parameters=creds.server_side_parameters,
                         )
                     )
@@ -574,6 +575,7 @@ def open(cls, connection: Connection) -> Connection:
                         SessionConnectionWrapper,
                     )
 
+                    # Pass session type (session or connect) into SessionConnectionWrapper
                     handle = SessionConnectionWrapper(
                         Connection(
                             conn_method=creds.method,