add line gaps after multi-line pydocs for consistency

Signed-off-by: varun-edachali-dbx <[email protected]>

Author: varun-edachali-dbx

src/databricks/sql/backend/types.py

@@ -57,6 +57,7 @@ def from_thrift_state(
             - CLOSED_STATE -> CLOSED
             - CANCELED_STATE -> CANCELLED
         """
+
         if state in (
             ttypes.TOperationState.INITIALIZED_STATE,
             ttypes.TOperationState.PENDING_STATE,
@@ -113,6 +114,7 @@ def __init__(
             secret: The secret part of the identifier (only used for Thrift)
             properties: Additional information about the session
         """
+
         self.backend_type = backend_type
         self.guid = guid
         self.secret = secret
@@ -128,6 +130,7 @@ def __str__(self) -> str:
         Returns:
             A string representation of the session ID
         """
+
         if self.backend_type == BackendType.SEA:
             return str(self.guid)
         elif self.backend_type == BackendType.THRIFT:
@@ -152,6 +155,7 @@ def from_thrift_handle(
         Returns:
             A SessionId instance
         """
+
         if session_handle is None:
             return None
 
@@ -178,6 +182,7 @@ def from_sea_session_id(
         Returns:
             A SessionId instance
         """
+
         return cls(BackendType.SEA, session_id, properties=properties)
 
     def to_thrift_handle(self):
@@ -187,6 +192,7 @@ def to_thrift_handle(self):
         Returns:
             A TSessionHandle object or None if this is not a Thrift session ID
         """
+
         if self.backend_type != BackendType.THRIFT:
             return None
 
@@ -205,6 +211,7 @@ def to_sea_session_id(self):
         Returns:
             The session ID string or None if this is not a SEA session ID
         """
+
         if self.backend_type != BackendType.SEA:
             return None
 
@@ -214,6 +221,7 @@ def get_guid(self) -> Any:
         """
         Get the ID of the session.
         """
+
         return self.guid
 
     def get_hex_guid(self) -> str:
@@ -223,6 +231,7 @@ def get_hex_guid(self) -> str:
         Returns:
             A hexadecimal string representation
         """
+
         if isinstance(self.guid, bytes):
             return guid_to_hex_id(self.guid)
         else:
@@ -236,6 +245,7 @@ def get_protocol_version(self):
             The server protocol version or None if it does not exist
             It is not expected to exist for SEA sessions.
         """
+
         return self.properties.get("serverProtocolVersion")
 
 
@@ -267,6 +277,7 @@ def __init__(
             has_result_set: Whether the command has a result set
             modified_row_count: The number of rows modified by the command
         """
+
         self.backend_type = backend_type
         self.guid = guid
         self.secret = secret
@@ -307,6 +318,7 @@ def from_thrift_handle(cls, operation_handle):
         Returns:
             A CommandId instance
         """
+
         if operation_handle is None:
             return None
 
@@ -333,6 +345,7 @@ def from_sea_statement_id(cls, statement_id: str):
         Returns:
             A CommandId instance
         """
+
         return cls(BackendType.SEA, statement_id)
 
     def to_thrift_handle(self):
@@ -342,6 +355,7 @@ def to_thrift_handle(self):
         Returns:
             A TOperationHandle object or None if this is not a Thrift command ID
         """
+
         if self.backend_type != BackendType.THRIFT:
             return None
 
@@ -362,6 +376,7 @@ def to_sea_statement_id(self):
         Returns:
             The statement ID string or None if this is not a SEA statement ID
         """
+
         if self.backend_type != BackendType.SEA:
             return None
 
@@ -374,6 +389,7 @@ def to_hex_guid(self) -> str:
         Returns:
             A hexadecimal string representation
         """
+
         if isinstance(self.guid, bytes):
             return guid_to_hex_id(self.guid)
         else:

src/databricks/sql/backend/utils/guid_utils.py

@@ -14,6 +14,7 @@ def guid_to_hex_id(guid: bytes) -> str:
     If conversion to hexadecimal fails, a string representation of the original
     bytes is returned
     """
+
     try:
         this_uuid = uuid.UUID(bytes=guid)
     except Exception as e:

src/databricks/sql/client.py

@@ -397,6 +397,7 @@ def __init__(
         Cursors are not isolated, i.e., any changes done to the database by a cursor are immediately
         visible by other cursors or connections.
         """
+
         self.connection = connection
         self.rowcount = -1  # Return -1 as this is not supported
         self.buffer_size_bytes = result_buffer_size_bytes
@@ -755,6 +756,7 @@ def execute(
 
         :returns self
         """
+
         logger.debug(
             "Cursor.execute(operation=%s, parameters=%s)", operation, parameters
         )
@@ -814,6 +816,7 @@ def execute_async(
         :param parameters:
         :return:
         """
+
         param_approach = self._determine_parameter_approach(parameters)
         if param_approach == ParameterApproach.NONE:
             prepared_params = NO_NATIVE_PARAMS

src/databricks/sql/session.py

@@ -31,6 +31,7 @@ def __init__(
 
         This class handles all session-related behavior and communication with the backend.
         """
+
         self.is_open = False
         self.host = server_hostname
         self.port = kwargs.get("_port", 443)

src/databricks/sql/types.py

@@ -158,6 +158,7 @@ def asDict(self, recursive: bool = False) -> Dict[str, Any]:
         >>> row.asDict(True) == {'key': 1, 'value': {'name': 'a', 'age': 2}}
         True
         """
+
         if not hasattr(self, "__fields__"):
             raise TypeError("Cannot convert a Row class into dict")
 
@@ -186,6 +187,7 @@ def __contains__(self, item: Any) -> bool:
     # let object acts like class
     def __call__(self, *args: Any) -> "Row":
         """create new Row object"""
+
         if len(args) > len(self):
             raise ValueError(
                 "Can not create Row with fields %s, expected %d values "
@@ -228,13 +230,15 @@ def __reduce__(
         self,
     ) -> Union[str, Tuple[Any, ...]]:
         """Returns a tuple so Python knows how to pickle Row."""
+
         if hasattr(self, "__fields__"):
             return (_create_row, (self.__fields__, tuple(self)))
         else:
             return tuple.__reduce__(self)
 
     def __repr__(self) -> str:
         """Printable representation of Row used in Python REPL."""
+
         if hasattr(self, "__fields__"):
             return "Row(%s)" % ", ".join(
                 "%s=%r" % (k, v) for k, v in zip(self.__fields__, tuple(self))

src/databricks/sql/utils.py

@@ -74,6 +74,7 @@ def build_queue(
         Returns:
             ResultSetQueue
         """
+
         if row_set_type == TSparkRowSetType.ARROW_BASED_SET:
             arrow_table, n_valid_rows = convert_arrow_based_set_to_arrow_table(
                 t_row_set.arrowBatches, lz4_compressed, arrow_schema_bytes
@@ -173,12 +174,14 @@ def __init__(
         :param n_valid_rows: The index of the last valid row in the table
         :param start_row_index: The first row in the table we should start fetching from
         """
+
         self.cur_row_index = start_row_index
         self.arrow_table = arrow_table
         self.n_valid_rows = n_valid_rows
 
     def next_n_rows(self, num_rows: int) -> "pyarrow.Table":
         """Get upto the next n rows of the Arrow dataframe"""
+
         length = min(num_rows, self.n_valid_rows - self.cur_row_index)
         # Note that the table.slice API is not the same as Python's slice
         # The second argument should be length, not end index
@@ -216,6 +219,7 @@ def __init__(
             lz4_compressed (bool): Whether the files are lz4 compressed.
             description (List[List[Any]]): Hive table schema description.
         """
+
         self.schema_bytes = schema_bytes
         self.max_download_threads = max_download_threads
         self.start_row_index = start_row_offset
@@ -256,6 +260,7 @@ def next_n_rows(self, num_rows: int) -> "pyarrow.Table":
         Returns:
             pyarrow.Table
         """
+
         if not self.table:
             logger.debug("CloudFetchQueue: no more rows available")
             # Return empty pyarrow table to cause retry of fetch
@@ -285,6 +290,7 @@ def remaining_rows(self) -> "pyarrow.Table":
         Returns:
             pyarrow.Table
         """
+
         if not self.table:
             # Return empty pyarrow table to cause retry of fetch
             return self._create_empty_table()
@@ -566,6 +572,7 @@ def transform_paramstyle(
     Returns:
         str
     """
+
     output = operation
     if (
         param_structure == ParameterStructure.POSITIONAL