fix: Fix the terminating of watch process

argoproj · Jun 21, 2021 · e6eec3d · e6eec3d
1 parent a939fe1
commit e6eec3d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/server/server.go b/server/server.go
@@ -292,7 +292,7 @@ func (s *ArgoRolloutsServer) WatchRolloutInfos(q *rollout.RolloutInfoListQuery,
 			return
 		}
 	}
-	ctx := context.Background()
+	ctx := ws.Context()
 	rolloutIf := s.Options.RolloutsClientset.ArgoprojV1alpha1().Rollouts(q.GetNamespace())
 
 	kubeInformerFactory := kubeinformers.NewSharedInformerFactoryWithOptions(s.Options.KubeClientset, 0, kubeinformers.WithNamespace(q.Namespace))