projects
/
arvados.git
/ blobdiff
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
20457: Log at info level when flapping lock at concurrency limit.
[arvados.git]
/
lib
/
dispatchcloud
/
cmd.go
diff --git
a/lib/dispatchcloud/cmd.go
b/lib/dispatchcloud/cmd.go
index 7ab38c6cabb0a6374621bcc63607f15fa4d64ddc..81982cdc1a7dad1a52c1b9bf05d34879ef7924ba 100644
(file)
--- a/
lib/dispatchcloud/cmd.go
+++ b/
lib/dispatchcloud/cmd.go
@@
-8,9
+8,9
@@
import (
"context"
"fmt"
"context"
"fmt"
- "git.
curoverse.com
/arvados.git/lib/cmd"
- "git.
curoverse.com
/arvados.git/lib/service"
- "git.
curoverse.com
/arvados.git/sdk/go/arvados"
+ "git.
arvados.org
/arvados.git/lib/cmd"
+ "git.
arvados.org
/arvados.git/lib/service"
+ "git.
arvados.org
/arvados.git/sdk/go/arvados"
"github.com/prometheus/client_golang/prometheus"
)
"github.com/prometheus/client_golang/prometheus"
)
@@
-21,6
+21,10
@@
func newHandler(ctx context.Context, cluster *arvados.Cluster, token string, reg
if err != nil {
return service.ErrorHandler(ctx, cluster, fmt.Errorf("error initializing client from cluster config: %s", err))
}
if err != nil {
return service.ErrorHandler(ctx, cluster, fmt.Errorf("error initializing client from cluster config: %s", err))
}
+ // Disable auto-retry. We have transient failure recovery at
+ // the application level, so we would rather receive/report
+ // upstream errors right away.
+ ac.Timeout = 0
d := &dispatcher{
Cluster: cluster,
Context: ctx,
d := &dispatcher{
Cluster: cluster,
Context: ctx,