Skip to content

Commit

Permalink
Increase some timeouts.
Browse files Browse the repository at this point in the history
  • Loading branch information
neunhoef committed Apr 11, 2019
1 parent 4aee700 commit 6401034
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions pkg/deployment/resources/deployment_health.go
Original file line number Diff line number Diff line change
Expand Up @@ -68,7 +68,7 @@ func (r *Resources) RunDeploymentHealthLoop(stopCh <-chan struct{}) {
// and stores it in-memory.
func (r *Resources) fetchDeploymentHealth() error {
// Ask cluster for its health
ctx, cancel := context.WithTimeout(context.Background(), time.Second*15)
ctx, cancel := context.WithTimeout(context.Background(), time.Minute)
defer cancel()
client, err := r.context.GetDatabaseClient(ctx)
if err != nil {
Expand Down Expand Up @@ -131,7 +131,7 @@ func (r *Resources) InvalidateSyncStatus() {
// fetchClusterShardSyncState performs a single fetch of the cluster inventory and
// checks if all shards are in sync
func (r *Resources) fetchClusterShardSyncState() error {
ctx, cancel := context.WithTimeout(context.Background(), time.Second*15)
ctx, cancel := context.WithTimeout(context.Background(), time.Minute*10)
defer cancel()
c, err := r.context.GetDatabaseClient(ctx)
if err != nil {
Expand Down

0 comments on commit 6401034

Please sign in to comment.