File tree Expand file tree Collapse file tree 3 files changed +7
-17
lines changed Expand file tree Collapse file tree 3 files changed +7
-17
lines changed Original file line number Diff line number Diff line change @@ -939,7 +939,7 @@ def execute_command(
939
939
logger .debug (
940
940
"ThriftBackend.execute_command(operation=%s, session_handle=%s)" ,
941
941
operation ,
942
- session_handle ,
942
+ thrift_handle ,
943
943
)
944
944
945
945
spark_arrow_types = ttypes .TSparkArrowTypes (
Original file line number Diff line number Diff line change @@ -250,18 +250,6 @@ def read(self) -> Optional[OAuthToken]:
250
250
+ str (self .get_session_id_hex ())
251
251
)
252
252
253
- # Create the session
254
- self .session = Session (
255
- server_hostname ,
256
- http_path ,
257
- http_headers ,
258
- session_configuration ,
259
- catalog ,
260
- schema ,
261
- _use_arrow_native_complex_types ,
262
- ** kwargs
263
- )
264
-
265
253
self .use_inline_params = self ._set_use_inline_params_with_warning (
266
254
kwargs .get ("use_inline_params" , False )
267
255
)
Original file line number Diff line number Diff line change @@ -84,16 +84,18 @@ def __init__(
84
84
** kwargs ,
85
85
)
86
86
87
+ def open (self ):
87
88
self ._session_id = self .backend .open_session (
88
- session_configuration = session_configuration , catalog = catalog , schema = schema
89
+ session_configuration = self .session_configuration ,
90
+ catalog = self .catalog ,
91
+ schema = self .schema ,
89
92
)
90
-
91
93
self .protocol_version = self .get_protocol_version (self ._session_id )
92
- self .open = True
94
+ self .is_open = True
93
95
logger .info ("Successfully opened session " + str (self .get_id_hex ()))
94
96
95
97
@staticmethod
96
- def get_protocol_version (sessionId : SessionId ):
98
+ def get_protocol_version (session_id : SessionId ):
97
99
"""
98
100
Since the sessionHandle will sometimes have a serverProtocolVersion, it takes
99
101
precedence over the serverProtocolVersion defined in the OpenSessionResponse.
You can’t perform that action at this time.
0 commit comments