Ella Rohm-Ensing 2ac5248387 Emit record counts in state messages for concurrent streams (#35907) ...

Co-authored-by: brianjlai <brian.lai@airbyte.io>
Co-authored-by: Brian Lai <51336873+brianjlai@users.noreply.github.com>

2024-03-08 19:08:59 -05:00

..

availability_strategy

Revert "[skip ci] formatting: add missing license headers (#33250)" (#33289)

2023-12-11 11:38:37 +01:00

config

🐛 Source S3: fix exception when setting CSV stream delimiter to \t. (#35246)

2024-02-23 14:34:29 -03:00

discovery_policy

Revert "[skip ci] formatting: add missing license headers (#33250)" (#33289)

2023-12-11 11:38:37 +01:00

file_types

file cdk: handle scalar values that resolve to None (#35688)

2024-03-05 09:07:02 -08:00

scenarios

CDK: assert >0 state messages per read (fix tests) (#35906)

2024-03-08 14:21:46 -08:00

schema_validation_policies

gradle: fix repo wide behaviour (#30607)

2023-09-28 05:01:13 -07:00

stream

Introduce FinalStateCursor to emit state messages at the end of full refresh syncs (#35905)

2024-03-08 16:58:26 -05:00

__init__.py

Revert "[skip ci] formatting: add missing license headers (#33250)" (#33289)

2023-12-11 11:38:37 +01:00

helpers.py

File-based CDK: make incremental syncs concurrent (#34540)

2024-02-07 20:41:04 -05:00

in_memory_files_source.py

File-based CDK: make full refresh concurrent (#34411)

2024-01-29 19:33:50 -05:00

test_file_based_scenarios.py

CDK: assert >0 state messages per read (fix tests) (#35906)

2024-03-08 14:21:46 -08:00

test_file_based_stream_reader.py

gradle: fix repo wide behaviour (#30607)

2023-09-28 05:01:13 -07:00

test_scenarios.py

Emit record counts in state messages for concurrent streams (#35907)

2024-03-08 19:08:59 -05:00

test_schema_helpers.py

gradle: fix repo wide behaviour (#30607)

2023-09-28 05:01:13 -07:00