type check

girarda · girarda · commit 448074d82d24 · 2025-03-06T17:25:39.000-08:00
diff --git a/airbyte_cdk/sources/streams/concurrent/adapters.py b/airbyte_cdk/sources/streams/concurrent/adapters.py
@@ -307,7 +307,7 @@ def read(self) -> Iterable[Record]:
                     and record_data.record is not None
                 ):
                     yield Record(
-                        data=record_data.record.data,
+                        data=record_data.record.data or {},
                         stream_name=self.stream_name(),
                         associated_slice=self._slice,  # type: ignore [arg-type]
                     )

Original file line number	Diff line number	Diff line change
`@@ -307,7 +307,7 @@ def read(self) -> Iterable[Record]:`
`307`	`307`	`and record_data.record is not None`
`308`	`308`	`):`
`309`	`309`	`yield Record(`
`310`		`- data=record_data.record.data,`
	`310`	`+ data=record_data.record.data or {},`
`311`	`311`	`stream_name=self.stream_name(),`
`312`	`312`	`associated_slice=self._slice, # type: ignore [arg-type]`
`313`	`313`	`)`