Skip to content

Commit

Permalink
pubsub: retry aborted
Browse files Browse the repository at this point in the history
Part 1 of 2 commits related to #1241.

Change-Id: I52ba65b31d207cf559c085b00d679eb56533cff3
Reviewed-on: https://code-review.googlesource.com/c/36110
Reviewed-by: kokoro <[email protected]>
Reviewed-by: Michael Darakananda <[email protected]>
  • Loading branch information
jeanbza committed Dec 6, 2018
1 parent e948dc9 commit 0683ccf
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion pubsub/service.go
Original file line number Diff line number Diff line change
Expand Up @@ -68,7 +68,7 @@ func isRetryable(err error) bool {
return true
}
switch s.Code() {
case codes.DeadlineExceeded, codes.Internal, codes.ResourceExhausted:
case codes.DeadlineExceeded, codes.Internal, codes.ResourceExhausted, codes.Aborted:
return true
case codes.Unavailable:
return !strings.Contains(s.Message(), "Server shutdownNow invoked")
Expand Down

0 comments on commit 0683ccf

Please sign in to comment.