-
Notifications
You must be signed in to change notification settings - Fork 3.8k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
AirbyteLib: Require stream selection #34979
Conversation
The latest updates on your projects. Learn more about Vercel for Git ↗︎ 1 Ignored Deployment
|
# TODO: The below assumes all sources can coalesce from incremental sync to | ||
# full_table as needed. CDK supports this, so it might be safe: | ||
sync_mode=SyncMode.incremental, |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This is a drive-by comment-revamp, not directly related to this PR.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
looks good to me!
With this change, users will be directed to call "select_streams()" or "select_all_streams()" if they attempt to call "source.read()" without having already done so.
Resolves:
read()
PyAirbyte#17This also renames "set_streams()" to "select_streams()" to align with the 'select' verb and 'selected' decriptor used elsewhere.
I've kept 'set_streams()' alive and still works, but it will now emit a
DeprecationWarning
when called, instructing users they should have calledselect_streams()
.I've also brought back
get_connector()
as an alias ofget_source()
using the same deprecation warning approach.