File tree Expand file tree Collapse file tree 3 files changed +19
-19
lines changed
unit_tests/sources/streams/concurrent Expand file tree Collapse file tree 3 files changed +19
-19
lines changed Original file line number Diff line number Diff line change 117117 "name" : "stream1" ,
118118 "supported_sync_modes" : ["full_refresh" ],
119119 "is_resumable" : False ,
120- "is_file_based" : False
120+ "is_file_based" : False ,
121121 }
122122 ]
123123 }
163163 "name" : "stream1" ,
164164 "supported_sync_modes" : ["full_refresh" ],
165165 "is_resumable" : False ,
166- "is_file_based" : False
166+ "is_file_based" : False ,
167167 }
168168 ]
169169 }
196196 "name" : "stream1" ,
197197 "supported_sync_modes" : ["full_refresh" ],
198198 "is_resumable" : False ,
199- "is_file_based" : False
199+ "is_file_based" : False ,
200200 }
201201 ]
202202 }
230230 "name" : "stream1" ,
231231 "supported_sync_modes" : ["full_refresh" ],
232232 "is_resumable" : False ,
233- "is_file_based" : False
233+ "is_file_based" : False ,
234234 },
235235 {
236236 "json_schema" : {
242242 "name" : "stream2" ,
243243 "supported_sync_modes" : ["full_refresh" ],
244244 "is_resumable" : False ,
245- "is_file_based" : False
245+ "is_file_based" : False ,
246246 },
247247 ]
248248 }
274274 "name" : "stream1" ,
275275 "supported_sync_modes" : ["full_refresh" ],
276276 "is_resumable" : False ,
277- "is_file_based" : False
277+ "is_file_based" : False ,
278278 }
279279 ]
280280 }
308308 "name" : "stream1" ,
309309 "supported_sync_modes" : ["full_refresh" ],
310310 "is_resumable" : False ,
311- "is_file_based" : False
311+ "is_file_based" : False ,
312312 }
313313 ]
314314 }
342342 "name" : "stream1" ,
343343 "supported_sync_modes" : ["full_refresh" ],
344344 "is_resumable" : False ,
345- "is_file_based" : False
345+ "is_file_based" : False ,
346346 }
347347 ]
348348 }
Original file line number Diff line number Diff line change 311311 "name" : "stream1" ,
312312 "supported_sync_modes" : ["full_refresh" ],
313313 "is_resumable" : False ,
314- "is_file_based" : False
314+ "is_file_based" : False ,
315315 }
316316 ]
317317 }
352352 "supported_sync_modes" : ["full_refresh" ],
353353 "source_defined_primary_key" : [["id" ]],
354354 "is_resumable" : False ,
355- "is_file_based" : False
355+ "is_file_based" : False ,
356356 }
357357 ]
358358 }
432432 "name" : "stream1" ,
433433 "supported_sync_modes" : ["full_refresh" ],
434434 "is_resumable" : False ,
435- "is_file_based" : False
435+ "is_file_based" : False ,
436436 },
437437 {
438438 "json_schema" : {
445445 "name" : "stream2" ,
446446 "supported_sync_modes" : ["full_refresh" ],
447447 "is_resumable" : False ,
448- "is_file_based" : False
448+ "is_file_based" : False ,
449449 },
450450 ]
451451 }
485485 "name" : "stream1" ,
486486 "supported_sync_modes" : ["full_refresh" ],
487487 "is_resumable" : False ,
488- "is_file_based" : False
488+ "is_file_based" : False ,
489489 }
490490 ]
491491 }
527527 "name" : "stream1" ,
528528 "supported_sync_modes" : ["full_refresh" ],
529529 "is_resumable" : False ,
530- "is_file_based" : False
530+ "is_file_based" : False ,
531531 }
532532 ]
533533 }
569569 "name" : "stream1" ,
570570 "supported_sync_modes" : ["full_refresh" ],
571571 "is_resumable" : False ,
572- "is_file_based" : False
572+ "is_file_based" : False ,
573573 }
574574 ]
575575 }
Original file line number Diff line number Diff line change @@ -151,7 +151,7 @@ def test_as_airbyte_stream_with_composite_primary_key(self):
151151 source_defined_primary_key = [["id_a" ], ["id_b" ]],
152152 namespace = None ,
153153 is_resumable = False ,
154- is_file_based = False
154+ is_file_based = False ,
155155 )
156156
157157 airbyte_stream = stream .as_airbyte_stream ()
@@ -220,7 +220,7 @@ def test_as_airbyte_stream_with_namespace(self):
220220 source_defined_primary_key = None ,
221221 namespace = "test" ,
222222 is_resumable = False ,
223- is_file_based = False
223+ is_file_based = False ,
224224 )
225225 actual_airbyte_stream = stream .as_airbyte_stream ()
226226
@@ -241,7 +241,7 @@ def test_as_airbyte_stream_with_file_transfer_support(self):
241241 message_repository = self ._message_repository ,
242242 ),
243243 namespace = "test" ,
244- supports_file_transfer = True
244+ supports_file_transfer = True ,
245245 )
246246 expected_airbyte_stream = AirbyteStream (
247247 name = self ._name ,
@@ -252,7 +252,7 @@ def test_as_airbyte_stream_with_file_transfer_support(self):
252252 source_defined_primary_key = None ,
253253 namespace = "test" ,
254254 is_resumable = False ,
255- is_file_based = True
255+ is_file_based = True ,
256256 )
257257 actual_airbyte_stream = stream .as_airbyte_stream ()
258258
You can’t perform that action at this time.
0 commit comments