@@ -352,39 +352,38 @@ func (impl *GitOpsConfigServiceImpl) createGitOpsConfig(ctx context.Context, req
352
352
}
353
353
}
354
354
}
355
- err = impl .gitOperationService .UpdateGitHostUrlByProvider (request )
355
+ }
356
+ err = impl .gitOperationService .UpdateGitHostUrlByProvider (request )
357
+ if err != nil {
358
+ return nil , err
359
+ }
360
+ operationComplete := false
361
+ retryCount := 0
362
+ for ! operationComplete && retryCount < 3 {
363
+ retryCount = retryCount + 1
364
+
365
+ cm , err := impl .K8sUtil .GetConfigMap (impl .aCDAuthConfig .ACDConfigMapNamespace , impl .aCDAuthConfig .ACDConfigMapName , client )
356
366
if err != nil {
357
367
return nil , err
358
368
}
359
- operationComplete := false
360
- retryCount := 0
361
- for ! operationComplete && retryCount < 3 {
362
- retryCount = retryCount + 1
363
-
364
- cm , err := impl .K8sUtil .GetConfigMap (impl .aCDAuthConfig .ACDConfigMapNamespace , impl .aCDAuthConfig .ACDConfigMapName , client )
365
- if err != nil {
366
- return nil , err
367
- }
368
- currentHost := request .Host
369
- updatedData := impl .updateData (cm .Data , request , impl .aCDAuthConfig .GitOpsSecretName , currentHost )
370
- data := cm .Data
371
- if data == nil {
372
- data = make (map [string ]string , 0 )
373
- }
374
- data ["repository.credentials" ] = updatedData ["repository.credentials" ]
375
- cm .Data = data
376
- _ , err = impl .K8sUtil .UpdateConfigMap (impl .aCDAuthConfig .ACDConfigMapNamespace , cm , client )
377
- if err != nil {
378
- continue
379
- }
380
- if err == nil {
381
- operationComplete = true
382
- }
369
+ currentHost := request .Host
370
+ updatedData := impl .updateData (cm .Data , request , impl .aCDAuthConfig .GitOpsSecretName , currentHost )
371
+ data := cm .Data
372
+ if data == nil {
373
+ data = make (map [string ]string , 0 )
383
374
}
384
- if ! operationComplete {
385
- return nil , fmt .Errorf ("resouce version not matched with config map attempted 3 times" )
375
+ data ["repository.credentials" ] = updatedData ["repository.credentials" ]
376
+ cm .Data = data
377
+ _ , err = impl .K8sUtil .UpdateConfigMap (impl .aCDAuthConfig .ACDConfigMapNamespace , cm , client )
378
+ if err != nil {
379
+ continue
380
+ } else {
381
+ operationComplete = true
386
382
}
387
383
}
384
+ if ! operationComplete {
385
+ return nil , fmt .Errorf ("resouce version not matched with config map attempted 3 times" )
386
+ }
388
387
}
389
388
390
389
// if git-ops config is created/saved successfully (just before transaction commit) and this was first git-ops config, then upsert clusters in acd
0 commit comments