We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f168624 commit 12f5cc7Copy full SHA for 12f5cc7
airbyte_cdk/sources/streams/concurrent/adapters.py
@@ -276,7 +276,7 @@ def __init__(
276
def read(self) -> Iterable[Record]:
277
"""
278
Read messages from the stream.
279
- If the StreamData is a Mapping, it will be converted to a Record.
+ If the StreamData is a Mapping or an AirbyteMessage of type RECORD, it will be converted to a Record.
280
Otherwise, the message will be emitted on the message repository.
281
282
try:
0 commit comments