diff --git a/lib/kube/proxy/sess.go b/lib/kube/proxy/sess.go index ebb38f7effc4c..1f761414ea177 100644 --- a/lib/kube/proxy/sess.go +++ b/lib/kube/proxy/sess.go @@ -1066,16 +1066,11 @@ func getRolesByName(forwarder *Forwarder, roleNames []string) ([]types.Role, err // on an interval until the session tracker is closed. func (s *session) trackSession(p *party, policySet []*types.SessionTrackerPolicySet) error { trackerSpec := types.SessionTrackerSpecV1{ - SessionID: s.id.String(), - Kind: string(types.KubernetesSessionKind), - State: types.SessionState_SessionStatePending, - Hostname: s.podName, - ClusterName: s.ctx.teleportCluster.name, - Participants: []types.Participant{{ - ID: p.ID.String(), - User: p.Ctx.User.GetName(), - LastActive: time.Now().UTC(), - }}, + SessionID: s.id.String(), + Kind: string(types.KubernetesSessionKind), + State: types.SessionState_SessionStatePending, + Hostname: s.podName, + ClusterName: s.ctx.teleportCluster.name, KubernetesCluster: s.ctx.kubeCluster, HostUser: p.Ctx.User.GetName(), HostPolicies: policySet, diff --git a/lib/srv/sess.go b/lib/srv/sess.go index 5b166672ec038..e8b10f43611f2 100644 --- a/lib/srv/sess.go +++ b/lib/srv/sess.go @@ -1075,10 +1075,6 @@ func (s *session) startInteractive(ch ssh.Channel, ctx *ServerContext, tempUser }() } - if err := s.addParty(p, types.SessionPeerMode); err != nil { - return trace.Wrap(err) - } - ctx.Debug("Waiting for continue signal") if tempUser != nil {