Skip to content

Conversation

@Sneagan
Copy link
Collaborator

@Sneagan Sneagan commented Mar 22, 2022

No description provided.

AmirSaber Sharifi and others added 6 commits December 9, 2021 23:38
Move Issuer Fetch Out of Loop
Experiment: Don't wait for processing to complete before committing the kafka offset
Append unmarshaling errors to the result set

Instead of using hard coded constants, create an enum to contain various
redemption statuses. This change does not remap the existing values and
so does not require an ads-serve change.
Rather than using a new enum, use the enum generated by gogen-avro for
status management.

Also make log lines shorter by splitting across multiple lines.
@Sneagan Sneagan requested a review from saberistic March 22, 2022 03:45
err = Emit(producer, resultSetBuffer.Bytes(), logger)
if err != nil {
message := fmt.Sprintf("Request %s: Failed to emit results to topic %s", tokenRedeemRequestSet.Request_id, producer.Topic)
message := fmt.Sprintf(

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

we should increase Prometheus counters on these unexpected cases and wire alert manager to notify us.

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

right before all return utils.ProcessingErrorFromErrorWithMessage(err, message, msg, logger) instructions

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants