admin/kubesphere
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request #3349 from LinuxSuRen/get-latest-resource-version

Browse Source 
Trying to avoid the error of `Operation cannot be fulfilled on` by getting the latest resourceVersion
This commit is contained in:
KubeSphere CI Bot
2021-02-20 10:11:18 +08:00
committed by GitHub
parent 2d73e777f4 ff384d30a6
commit 5972c4b66a
1 changed files with 12 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
pkg/models/devops/devops.go
View File

@@ -251,9 +251,18 @@ func (d devopsOperator) UpdatePipelineObj(projectName string, pipeline *v1alpha3
if err != nil {
return nil, err
}
projectObj.Annotations[devopsv1alpha3.PipelineSyncStatusAnnoKey] = StatusPending
projectObj.Annotations[devopsv1alpha3.PipelineSyncTimeAnnoKey] = GetSyncNowTime()
return d.ksclient.DevopsV1alpha3().Pipelines(projectObj.Status.AdminNamespace).Update(context.Background(), pipeline, metav1.UpdateOptions{})
ctx := context.Background()
ns := projectObj.Status.AdminNamespace
name := pipeline.GetName()
// trying to avoid the error of `Operation cannot be fulfilled on` by getting the latest resourceVersion
if latestPipe, err := d.ksclient.DevopsV1alpha3().Pipelines(ns).Get(ctx, name, metav1.GetOptions{}); err == nil {
pipeline.ResourceVersion = latestPipe.ResourceVersion
} else {
return nil, fmt.Errorf("cannot found pipeline %s/%s, error: %v", ns, name, err)
}
return d.ksclient.DevopsV1alpha3().Pipelines(ns).Update(context.Background(), pipeline, metav1.UpdateOptions{})
}
func (d devopsOperator) ListPipelineObj(projectName string, sortFunc func([]*v1alpha3.Pipeline, int, int) bool, limit, offset int) (api.ListResult, error) {