format

Author: girarda

airbyte_cdk/sources/streams/concurrent/adapters.py

@@ -302,10 +302,7 @@ def read(self) -> Iterable[Record]:
                         stream_name=self.stream_name(),
                         associated_slice=self._slice,  # type: ignore [arg-type]
                     )
-                elif (
-                    isinstance(record_data, AirbyteMessage)
-                    and record_data.record is not None
-                ):
+                elif isinstance(record_data, AirbyteMessage) and record_data.record is not None:
                     yield Record(
                         data=record_data.record.data or {},
                         stream_name=self.stream_name(),