File tree Expand file tree Collapse file tree
airbyte_cdk/sources/declarative/parsers Expand file tree Collapse file tree Original file line number Diff line number Diff line change 104104 RecordSelector ,
105105 ResponseToFileExtractor ,
106106)
107- from airbyte_cdk .sources .declarative .expanders .record_expander import RecordExpander
108107from airbyte_cdk .sources .declarative .extractors .record_extractor import RecordExtractor
109108from airbyte_cdk .sources .declarative .extractors .record_filter import (
110109 ClientSideIncrementalRecordFilterDecorator ,
@@ -2350,7 +2349,9 @@ def create_record_expander(
23502349 config = config ,
23512350 parameters = model .parameters or {},
23522351 remain_original_record = model .remain_original_record or False ,
2353- on_no_records = OnNoRecords (model .on_no_records .value ) if model .on_no_records else OnNoRecords .skip ,
2352+ on_no_records = OnNoRecords (model .on_no_records .value )
2353+ if model .on_no_records
2354+ else OnNoRecords .skip ,
23542355 )
23552356
23562357 @staticmethod
Original file line number Diff line number Diff line change @@ -427,4 +427,3 @@ def test_dpath_extractor_on_no_records(
427427 actual_records = list (extractor .extract_records (response ))
428428
429429 assert actual_records == expected_records
430-
You can’t perform that action at this time.
0 commit comments