MOD: Suppress exception chains for BentoError

Author: nmacholl

databento/common/dbnstore.py

@@ -1319,7 +1319,7 @@ def __next__(self) -> np.ndarray[Any, Any]:
         except ValueError:
             raise BentoError(
                 "DBN file is truncated or contains an incomplete record",
-            )
+            ) from None
 
 
 class DataFrameIterator:

databento/historical/api/batch.py

@@ -376,7 +376,7 @@ def _download_file(
                     for chunk in response.iter_content(chunk_size=None):
                         f.write(chunk)
                 except Exception as exc:
-                    raise BentoError(f"Error downloading file: {exc}")
+                    raise BentoError(f"Error downloading file: {exc}") from None
             logger.debug("Download of %s completed", output_path.name)
 
     async def download_async(
@@ -521,7 +521,7 @@ async def _download_file_async(
                             data: bytes = chunk[0]
                             f.write(data)
                     except Exception as exc:
-                        raise BentoError(f"Error downloading file: {exc}")
+                        raise BentoError(f"Error downloading file: {exc}") from None
                 logger.debug("Download of %s completed", output_path.name)
 
     def _get_file_download_headers_and_mode(

databento/historical/http.py

@@ -137,7 +137,7 @@ def _stream(
                 for chunk in response.iter_content(chunk_size=None):
                     writer.write(chunk)
             except Exception as exc:
-                raise BentoError(f"Error streaming response: {exc}")
+                raise BentoError(f"Error streaming response: {exc}") from None
 
             if path is None:
                 writer.seek(0)
@@ -177,7 +177,7 @@ async def _stream_async(
                     async for chunk in response.content.iter_chunks():
                         writer.write(chunk[0])
                 except Exception as exc:
-                    raise BentoError(f"Error streaming response: {exc}")
+                    raise BentoError(f"Error streaming response: {exc}") from None
 
                 if path is None:
                     writer.seek(0)

databento/live/session.py

@@ -414,12 +414,12 @@ async def wait_for_close(self) -> None:
         try:
             self._protocol.authenticated.result()
         except Exception as exc:
-            raise BentoError(exc)
+            raise BentoError(exc) from None
 
         try:
             self._protocol.disconnected.result()
         except Exception as exc:
-            raise BentoError(exc)
+            raise BentoError(exc) from None
 
         self._protocol = self._transport = None