fix: Update RecordExpander to return nothing when path doesn't exist

Changes:
- Add back 'else: yield from []' in DpathExtractor for explicit empty case
- Update RecordExpander to return nothing when expand_records_from_field path doesn't exist or isn't a list
- Update unit tests to expect no records instead of original record when expansion fails

This makes RecordExpander stricter: it only emits records when successfully expanding a list.
For Stripe invoice_line_items, this ensures we only emit line items, not invoice objects.

All 24 tests passing. Requested by @DanyloGL.

Co-Authored-By: unknown <>

Author: devin-ai-integration[bot]

airbyte_cdk/sources/declarative/expanders/record_expander.py

@@ -58,11 +58,9 @@ def expand_record(self, record: MutableMapping[Any, Any]) -> Iterable[MutableMap
         try:
             nested_array = dpath.get(record, expand_path)
         except (KeyError, TypeError):
-            yield record
             return
 
         if not isinstance(nested_array, list):
-            yield record
             return
 
         if len(nested_array) == 0:

airbyte_cdk/sources/declarative/extractors/dpath_extractor.py

@@ -111,3 +111,5 @@ def extract_records(self, response: requests.Response) -> Iterable[MutableMappin
                     yield from self.record_expander.expand_record(extracted)
                 else:
                     yield extracted
+            else:
+                yield from []

unit_tests/sources/declarative/extractors/test_dpath_extractor.py

@@ -191,14 +191,14 @@ def test_dpath_extractor(field_path: List, decoder: Decoder, body, expected_reco
             ["items"],
             False,
             {"data": {"id": "parent_1"}},
-            [{"id": "parent_1"}],
+            [],
         ),
         (
             ["data"],
             ["items"],
             False,
             {"data": {"id": "parent_1", "items": "not_an_array"}},
-            [{"id": "parent_1", "items": "not_an_array"}],
+            [],
         ),
         (
             ["data"],
@@ -234,8 +234,8 @@ def test_dpath_extractor(field_path: List, decoder: Decoder, body, expected_reco
         "test_expand_nested_array",
         "test_expand_with_original_record",
         "test_expand_empty_array_yields_nothing",
-        "test_expand_missing_path_yields_original",
-        "test_expand_non_array_yields_original",
+        "test_expand_missing_path_yields_nothing",
+        "test_expand_non_array_yields_nothing",
         "test_expand_deeply_nested_path",
         "test_expand_mixed_types_in_array",
         "test_expand_multiple_parent_records",