File tree 1 file changed +6
-1
lines changed
cmdexec/clients/python/src/databricks/sql
1 file changed +6
-1
lines changed Original file line number Diff line number Diff line change 10
10
11
11
from databricks .sql import USER_AGENT_NAME , __version__
12
12
from databricks .sql import *
13
+ from databricks .sql .exc import OperationalError
13
14
from databricks .sql .thrift_backend import ThriftBackend
14
15
from databricks .sql .utils import ExecuteResponse , ParamEscaper
15
16
from databricks .sql .types import Row
@@ -123,7 +124,11 @@ def __del__(self):
123
124
if self .open :
124
125
logger .debug ("Closing unclosed connection for session "
125
126
"{}" .format (self .get_session_id ()))
126
- self ._close (close_cursors = False )
127
+ try :
128
+ self ._close (close_cursors = False )
129
+ except OperationalError as e :
130
+ # Close on best-effort basis.
131
+ logger .debug ("Couldn't close unclosed connection: {}" .format (e .message ))
127
132
128
133
def get_session_id (self ):
129
134
return self .thrift_backend .handle_to_id (self ._session_handle )
You can’t perform that action at this time.
0 commit comments