invalidate repo cache on delete (argoproj#1182)

Signed-off-by: Nestor <[email protected]>
tkasuz · Feb 26, 2019 · caacba9 · caacba9
1 parent 2f62d1b
commit caacba9
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/server/repository/repository.go b/server/repository/repository.go
@@ -351,6 +351,12 @@ func (s *Server) Delete(ctx context.Context, q *RepoQuery) (*RepoResponse, error
 	if !s.enf.Enforce(ctx.Value("claims"), rbacpolicy.ResourceRepositories, rbacpolicy.ActionDelete, q.Repo) {
 		return nil, grpc.ErrPermissionDenied
 	}
+
+	// invalidate cache
+	if err := s.cache.SetRepoConnectionState(q.Repo, nil); err == nil {
+		log.Errorf("error invalidating cache: %v", err)
+	}
+
 	err := s.db.DeleteRepository(ctx, q.Repo)
 	return &RepoResponse{}, err
 }