mypy

Author: maxime.c

airbyte_cdk/sources/streams/concurrent/default_stream.py

@@ -109,7 +109,7 @@ def check_availability(self) -> StreamAvailability:
                 f"Cannot attempt to connect to stream {self.name} - no stream slices were found"
             )
         except AirbyteTracedException as error:
-            return StreamAvailability.unavailable(error.message)
+            return StreamAvailability.unavailable(error.message or error.internal_message or "<no error message>")
 
         try:
             next(iter(partition.read()))
@@ -118,4 +118,4 @@ def check_availability(self) -> StreamAvailability:
             self._logger.info(f"Successfully connected to stream {self.name}, but got 0 records.")
             return StreamAvailability.available()
         except AirbyteTracedException as error:
-            return StreamAvailability.unavailable(error.message)
+            return StreamAvailability.unavailable(error.message or error.internal_message or "<no error message>")