Index: logdog/client/butler/output/pubsub/pubsubOutput.go |
diff --git a/logdog/client/butler/output/pubsub/pubsubOutput.go b/logdog/client/butler/output/pubsub/pubsubOutput.go |
index 841c34b10f208a0e96f04fa8820789b42e1530e0..05bfb2e30890593568d318e605aab7c299408b7d 100644 |
--- a/logdog/client/butler/output/pubsub/pubsubOutput.go |
+++ b/logdog/client/butler/output/pubsub/pubsubOutput.go |
@@ -205,7 +205,7 @@ func (o *pubSubOutput) publishMessage(message *pubsub.Message) error { |
messageID, err = o.Topic.Publish(ctx, message) |
if err == context.DeadlineExceeded { |
// If we hit our publish deadline, retry. |
- err = errors.WrapTransient(err) |
+ err = retry.Tag.Apply(err) |
} else { |
err = grpcutil.WrapIfTransient(err) |
} |