From 5460eccb7b2f7cc5719becac437bd884d7f926fc Mon Sep 17 00:00:00 2001 From: Ashish-devtron Date: Wed, 22 Nov 2023 17:13:20 +0530 Subject: [PATCH] get rest config for external namespace only --- pkg/pipeline/CiHandler.go | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/pkg/pipeline/CiHandler.go b/pkg/pipeline/CiHandler.go index 82d9faf391..84cc5d551b 100644 --- a/pkg/pipeline/CiHandler.go +++ b/pkg/pipeline/CiHandler.go @@ -1640,6 +1640,7 @@ func (impl *CiHandlerImpl) UpdateCiWorkflowStatusFailure(timeoutForFailureCiBuil for _, ciWorkflow := range ciWorkflows { var isExt bool var env *repository3.Environment + var restConfig *rest.Config if ciWorkflow.Namespace != DefaultCiWorkflowNamespace { isExt = true env, err = impl.envRepository.FindById(ciWorkflow.EnvironmentId) @@ -1647,16 +1648,16 @@ func (impl *CiHandlerImpl) UpdateCiWorkflowStatusFailure(timeoutForFailureCiBuil impl.Logger.Errorw("could not fetch stage env", "err", err) return err } + restConfig, err = impl.getRestConfig(ciWorkflow) + if err != nil { + return err + } } isEligibleToMarkFailed := false isPodDeleted := false if time.Since(ciWorkflow.StartedOn) > (time.Minute * time.Duration(timeoutForFailureCiBuild)) { - restConfig, err := impl.getRestConfig(ciWorkflow) - if err != nil { - return err - } //check weather pod is exists or not, if exits check its status wf, err := impl.workflowService.GetWorkflowStatus(ciWorkflow.ExecutorType, ciWorkflow.Name, ciWorkflow.Namespace, restConfig) if err != nil {