@@ -462,13 +462,12 @@ def attempt_request(attempt):
462462 errno .ECONNRESET , # | 104 | 54 |
463463 errno .ETIMEDOUT , # | 110 | 60 |
464464 ]
465+ # fmt: on
465466
466467 gos_name = TCLIServiceClient .GetOperationStatus .__name__
467468 # retry on timeout. Happens a lot in Azure and it is safe as data has not been sent to server yet
468469 if method .__name__ == gos_name or err .errno == errno .ETIMEDOUT :
469470 retry_delay = bound_retry_delay (attempt , self ._retry_delay_default )
470-
471- # fmt: on
472471 log_string = f"{ gos_name } failed with code { err .errno } and will attempt to retry"
473472 if err .errno in info_errs :
474473 logger .info (log_string )
@@ -517,9 +516,7 @@ def attempt_request(attempt):
517516 if not isinstance (response_or_error_info , RequestErrorInfo ):
518517 # log nothing here, presume that main request logging covers
519518 response = response_or_error_info
520- ThriftDatabricksClient ._check_response_for_error (
521- response , self ._host
522- )
519+ ThriftDatabricksClient ._check_response_for_error (response , self ._host )
523520 return response
524521
525522 error_info = response_or_error_info
@@ -779,9 +776,7 @@ def _col_to_description(col, field=None, host_url=None):
779776 return col .columnName , cleaned_type , None , None , precision , scale , None
780777
781778 @staticmethod
782- def _hive_schema_to_description (
783- t_table_schema , schema_bytes = None , host_url = None
784- ):
779+ def _hive_schema_to_description (t_table_schema , schema_bytes = None , host_url = None ):
785780 field_dict = {}
786781 if pyarrow and schema_bytes :
787782 try :
0 commit comments