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
CDK: Fix regression in _checkpoint_state
arg
#16141
Conversation
Signed-off-by: Sergey Chvalyuk <grubberr@gmail.com>
_checkpoint_state
arg
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.
@grubberr can you edit the PR description to include a description of the problem, an example, and why this code change fixes it?
@sherifnada I think the context is https://github.com/airbytehq/oncall/issues/466 I don't think I can competently review this PR, I have basically no experience with CDK internals; removing my review request. LMK if there's anything I can do to help get this deployed though. couple drive-by comments while I'm here:
|
/publish-cdk dry-run=true
|
Signed-off-by: Sergey Chvalyuk <grubberr@gmail.com>
FYI @sherifnada @lazebnyi @bazarnov @davydov-d @roman-yermilov-gl New pydantic released from pydantic import BaseModel, Field
class Choice1(BaseModel):
field = Field("option1", const=True)
Maybe we would need to return |
As an option we could pin pydantic version not to change/during the change will be made to all the models in the connectors |
Yeah we can’t upgrade pydantic or it will cause issues. |
SAT updates for new pydantic #16172 |
Signed-off-by: Sergey Chvalyuk <grubberr@gmail.com>
This reverts commit ba67ba0.
@sherifnada I have pinned |
/publish-cdk dry-run=true
|
/publish-cdk dry-run=false |
2 similar comments
/publish-cdk dry-run=false |
/publish-cdk dry-run=false |
/publish-cdk dry-run=false
|
Signed-off-by: Sergey Chvalyuk <grubberr@gmail.com>
Signed-off-by: Sergey Chvalyuk grubberr@gmail.com
What
Fix incorrect use of
self._checkpoint_state
we need to pass
stream_state
becausestream_instance.state
can be undefined