Skip to content

Commit d6b8277

Browse files
committed
fix yield from
1 parent 72a27f3 commit d6b8277

File tree

1 file changed

+2
-1
lines changed
  • airbyte-integrations/connectors/source-orb/source_orb

1 file changed

+2
-1
lines changed

airbyte-integrations/connectors/source-orb/source_orb/source.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -269,7 +269,7 @@ def parse_response(
269269
response_json = response.json()
270270
records = response_json.get("data", [])
271271
for record in records:
272-
self.yield_transformed_subrecords(record, subscription_id)
272+
yield from self.yield_transformed_subrecords(record, subscription_id)
273273

274274
def next_page_token(self, response: requests.Response) -> Optional[Mapping[str, Any]]:
275275
# This API endpoint is not paginated, so there will never be a next page
@@ -305,6 +305,7 @@ def yield_transformed_subrecords(self, record, subscription_id):
305305
del output["metric_group"]
306306
output[nested_key] = nested_value
307307
yield output
308+
yield from []
308309

309310
def request_params(self, stream_state: Mapping[str, Any], stream_slice: Mapping[str, any] = None, **kwargs) -> MutableMapping[str, Any]:
310311
"""

0 commit comments

Comments
 (0)