Skip to content

Commit 297a395

Browse files
authored
fix: manual app sync (#4449)
1 parent ca6e77f commit 297a395

File tree

1 file changed

+2
-11
lines changed

1 file changed

+2
-11
lines changed

pkg/chartRepo/ChartRepositoryService.go

Lines changed: 2 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,6 @@ import (
2525
util3 "github.com/devtron-labs/common-lib/utils/k8s"
2626
"io"
2727
"io/ioutil"
28-
v1 "k8s.io/api/batch/v1"
2928
"net/http"
3029
"net/url"
3130
"strings"
@@ -712,17 +711,9 @@ func (impl *ChartRepositoryServiceImpl) TriggerChartSyncManual(chartProviderConf
712711
}
713712

714713
manualAppSyncJobByteArr := manualAppSyncJobByteArr(impl.serverEnvConfig.AppSyncImage, impl.serverEnvConfig.AppSyncJobResourcesObj, chartProviderConfig)
715-
716-
var job v1.Job
717-
err = yaml.Unmarshal(manualAppSyncJobByteArr, &job)
718-
if err != nil {
719-
impl.logger.Errorw("Unmarshal err, CreateJobSafely", "err", err)
720-
return err
721-
}
722-
723-
err = impl.K8sUtil.CreateJob(impl.aCDAuthConfig.ACDConfigMapNamespace, job.Name, defaultClusterConfig, &job)
714+
err = impl.K8sUtil.DeleteAndCreateJob(manualAppSyncJobByteArr, impl.aCDAuthConfig.ACDConfigMapNamespace, defaultClusterConfig)
724715
if err != nil {
725-
impl.logger.Errorw("CreateJob err, CreateJobSafely", "err", err)
716+
impl.logger.Errorw("DeleteAndCreateJob err, TriggerChartSyncManual", "err", err)
726717
return err
727718
}
728719

0 commit comments

Comments
 (0)