import (
"context"
"fmt"
+ "time"
"git.arvados.org/arvados.git/lib/cmd"
"git.arvados.org/arvados.git/lib/service"
if err != nil {
return service.ErrorHandler(ctx, cluster, fmt.Errorf("error initializing client from cluster config: %s", err))
}
+ client.Timeout = time.Minute
eventSource := &pgEventSource{
DataSource: cluster.PostgreSQL.Connection.String(),
MaxOpenConns: cluster.PostgreSQL.ConnectionPool,