Increase the amount of time session trackers linger

lib/events/stream.go

@@ -685,6 +685,7 @@ func (w *sliceWriter) completeStream() {
 		sort.Slice(w.completedParts, func(i, j int) bool {
 			return w.completedParts[i].Number < w.completedParts[j].Number
 		})
+
 		err := w.proto.cfg.Uploader.CompleteUpload(w.proto.cancelCtx, w.proto.cfg.Upload, w.completedParts)
 		w.proto.setCompleteResult(err)
 		if err != nil {

lib/services/local/sessiontracker.go

@@ -34,9 +34,17 @@ import (
 const (
 	sessionPrefix   = "session_tracker"
 	retryDelay      = time.Second
-	terminatedTTL   = 3 * time.Minute
 	casRetryLimit   = 7
 	casErrorMessage = "CompareAndSwap reached retry limit"
+
+	// terminatedTTL is the TTL we set when a session tracker
+	// is put in a terminated state.
+	//
+	// Teleport's upload completer will attempt ot operate on any
+	// session that does not contain an active session tracker, so
+	// we choose a value here that will give sessions enough time
+	// to be uploaded.
+	terminatedTTL = 90 * time.Minute
 )
 
 type sessionTracker struct {

lib/srv/sessiontracker.go

@@ -67,7 +67,8 @@ func NewSessionTracker(ctx context.Context, trackerSpec types.SessionTrackerSpec
 	}, nil
 }
 
-// Close closes the session tracker and sets the tracker state to terminated
+// Close closes the session tracker and sets the tracker state to terminated.
+// The tracker will remain in a terminated state until it expires from the backend.
 func (s *SessionTracker) Close(ctx context.Context) error {
 	close(s.closeC)
 	err := s.UpdateState(ctx, types.SessionState_SessionStateTerminated)