-
Notifications
You must be signed in to change notification settings - Fork 455
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
[coordinator] Marshal return val of kv handler with jsonpb #3116
Conversation
oldProtoMarshalled := bytes.NewBuffer(nil) | ||
if err := (&jsonpb.Marshaler{}).Marshal(oldProtoMarshalled, oldProto); err != nil { | ||
return nil, fmt.Errorf("failed to marshal old proto: %w", err) | ||
} |
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.
Hm actually should this error out if it couldn't get previous, or just log a warning? Otherwise potential you get stuck on a poisoned message and can't roll forward, e.g. if we change the format of the proto at some point?
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.
hmm good call, will do
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.
ah yeah there's already a similar message above
Codecov Report
@@ Coverage Diff @@
## master #3116 +/- ##
=======================================
Coverage 72.2% 72.2%
=======================================
Files 1084 1084
Lines 100203 100206 +3
=======================================
+ Hits 72436 72442 +6
- Misses 22729 22731 +2
+ Partials 5038 5033 -5
Flags with carried forward coverage won't be shown. Click here to find out more. Continue to review full report at Codecov.
|
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
Does this PR introduce a user-facing and/or backwards incompatible change?:
NONE
Does this PR require updating code package or user-facing documentation?:
NONE