File tree Expand file tree Collapse file tree 1 file changed +6
-2
lines changed
airbyte_cdk/sources/streams/concurrent Expand file tree Collapse file tree 1 file changed +6
-2
lines changed Original file line number Diff line number Diff line change @@ -109,7 +109,9 @@ def check_availability(self) -> StreamAvailability:
109109 f"Cannot attempt to connect to stream { self .name } - no stream slices were found"
110110 )
111111 except AirbyteTracedException as error :
112- return StreamAvailability .unavailable (error .message or error .internal_message or "<no error message>" )
112+ return StreamAvailability .unavailable (
113+ error .message or error .internal_message or "<no error message>"
114+ )
113115
114116 try :
115117 next (iter (partition .read ()))
@@ -118,4 +120,6 @@ def check_availability(self) -> StreamAvailability:
118120 self ._logger .info (f"Successfully connected to stream { self .name } , but got 0 records." )
119121 return StreamAvailability .available ()
120122 except AirbyteTracedException as error :
121- return StreamAvailability .unavailable (error .message or error .internal_message or "<no error message>" )
123+ return StreamAvailability .unavailable (
124+ error .message or error .internal_message or "<no error message>"
125+ )
You can’t perform that action at this time.
0 commit comments