projects
/
arvados.git
/ blobdiff
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
19973: Limit container concurrency when API is returning 503.
[arvados.git]
/
cmd
/
arvados-client
/
container_gateway.go
diff --git
a/cmd/arvados-client/container_gateway.go
b/cmd/arvados-client/container_gateway.go
index aca6c5b797fa4ec3b036ee8300ae3f4fcbe5e885..55f8c33bc70c77d31f13f16bb924ee4c2a6a1613 100644
(file)
--- a/
cmd/arvados-client/container_gateway.go
+++ b/
cmd/arvados-client/container_gateway.go
@@
-160,7
+160,9
@@
Options:
fmt.Fprintf(stderr, "target UUID is not a container or container request UUID: %s\n", targetUUID)
return 1
}
fmt.Fprintf(stderr, "target UUID is not a container or container request UUID: %s\n", targetUUID)
return 1
}
- sshconn, err := rpcconn.ContainerSSH(context.TODO(), arvados.ContainerSSHOptions{
+ ctx, cancel := context.WithCancel(context.Background())
+ defer cancel()
+ sshconn, err := rpcconn.ContainerSSH(ctx, arvados.ContainerSSHOptions{
UUID: targetUUID,
DetachKeys: *detachKeys,
LoginUsername: loginUsername,
UUID: targetUUID,
DetachKeys: *detachKeys,
LoginUsername: loginUsername,
@@
-176,7
+178,6
@@
Options:
return 0
}
return 0
}
- ctx, cancel := context.WithCancel(context.Background())
go func() {
defer cancel()
_, err := io.Copy(stdout, sshconn.Conn)
go func() {
defer cancel()
_, err := io.Copy(stdout, sshconn.Conn)