diff --git a/instancemanager/kubernetes/instance_manager.go b/instancemanager/kubernetes/instance_manager.go index 1a12dae..f9b2813 100644 --- a/instancemanager/kubernetes/instance_manager.go +++ b/instancemanager/kubernetes/instance_manager.go @@ -3,6 +3,7 @@ package kubernetes import ( "context" "io" + "log" "os" "path/filepath" "strings" @@ -250,8 +251,8 @@ func (i *InstanceManager) InteractiveTerminal(ctx context.Context, serverId stri req := i.coreV1Cli.CoreV1().RESTClient(). Post(). Resource("pods"). - Namespace(i.Config.Namespace). Name(serverId). + Namespace(i.Config.Namespace). SubResource("attach"). VersionedParams(&corev1.PodAttachOptions{ Stdin: true, @@ -264,7 +265,10 @@ func (i *InstanceManager) InteractiveTerminal(ctx context.Context, serverId stri go func() { defer stdoutWriter.Close() defer stdinReader.Close() - _ = executor.StreamWithContext(ctx, remotecommand.StreamOptions{Stdin: stdinReader, Stdout: stdoutWriter, Stderr: stdoutWriter, Tty: true, TerminalSizeQueue: queue}) + err := executor.StreamWithContext(ctx, remotecommand.StreamOptions{Stdin: stdinReader, Stdout: stdoutWriter, Stderr: stdoutWriter, Tty: true, TerminalSizeQueue: queue}) + if err != nil { + log.Printf("Failed to attach %e", err) + } }() if err != nil {