-
Notifications
You must be signed in to change notification settings - Fork 4.1k
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
🚨🚨 Source JIRA: Save state for Boards Issues per board #33715
Conversation
The latest updates on your projects. Learn more about Vercel for Git ↗︎ 1 Ignored Deployment
|
Warning 🚨 Connector code freeze is in effect until 2024-01-02. This PR is changing connector code. Please contact the current OC engineers if you want to merge this change to master. |
Before Merging a Connector Pull RequestWow! What a great pull request you have here! 🎉 To merge this PR, ensure the following has been done/considered for each connector added or updated:
If the checklist is complete, but the CI check is failing,
|
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.
lgtm
need small changes
board_id = str(stream_slice["board_id"]) | ||
if stream_state: |
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.
you don't need assign board_id before if statement. It's used only stream_state
not false.
@@ -288,17 +296,45 @@ def should_retry(self, response: requests.Response) -> bool: | |||
# for all other HTTP errors the default handling is applied | |||
return super().should_retry(response) | |||
|
|||
def stream_slices(self, **kwargs) -> Iterable[Optional[Mapping[str, Any]]]: | |||
self._starting_point_cache.clear() |
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.
please add comment why we need do this
What
Resolving https://github.com/airbytehq/oncall/issues/3757
How
Save State for every
board
in streamBoards Issues
Recommended reading order
streams.py
🚨 User Impact 🚨
state has changes for stream
Boards Issues
Pre-merge Actions
Updating a connector
Community member or Airbyter
Airbyter
If this is a community PR, the Airbyte engineer reviewing this PR is responsible for the below items.