Brian Lai

[per-stream state] add new SAT tests to verify per-stream state correctness

5

Closes #16059 ## What Adds two new incremental test to the existing test_incremental suite. They behave functionally very similar to the existing tests `test_per_stream_two_sequential_reads()` and `test_per_stream_read_sequential_slices()`, but with some additional...

This epic comprises all the tasks required to allow for per-stream state for API source connectors that implement the CDK. It is broken into two milestones. The first is all...

Most API source connectors should be able to start emitting per stream state by just updating to the latest version of the CDK once the changes are released on a...

Closes https://github.com/airbytehq/airbyte/issues/16055 ## What A previous PR added support for reading in legacy state object and store it in the `ConnectorStateManager` which would then be used for updating/retrieving state. This...

## What is the problem Originally identified from work on another PR here: https://github.com/airbytehq/airbyte/pull/20861#discussion_r1062971659 From the substream slicer, we currently allow for developers to attempt to inject values into the...

## What We have had a lot of changes added into the `low_code_cdk_to_beta` branch. We review PRs before they merge into that branch, but we should collectively review things one...

[Low-Code CDK] Remove stream_cursor_field from DeclarativeStream

1

## Tell us about the problem you're trying to solve **BREAKING CHANGE** We redundantly define the cursor field for incremental streams in multiple places on both the `DeclarativeStream.stream_cursor_field` and stream_slicer's...

[Low-Code CDK] Rremove stream_cursor_field from stream and derive it from stream_slicer

1

Closes https://github.com/airbytehq/airbyte/issues/21561 ## What For connectors that implement incremental syncs, we currently require that the cursor be specified in two location. `stream_cursor_field` on DeclarativeStream and `cursor_field` on various Stream Slicers....

[RFR for API Sources] New Python interfaces to support resumable full refresh

1

## What Primarily updates how the Stream class performs a read. The big change is around how we resolve what the next partition of records to retrieve is. Because resumable...

✨ [source-hubspot] Implement RFR for contacts_form_submissions, contact_list_memberships, contact_merged_audit

4

Closes https://github.com/airbytehq/airbyte-internal-issues/issues/7047 ## What There are 5 Hubspot streams that only support full refresh. I've implemented 3 of them: - contacts_form_submissions - contact_list_memberships - contact_merged_audit I did not implement the...