diff --git a/pkg/chartRepo/ChartRepositoryService.go b/pkg/chartRepo/ChartRepositoryService.go
index f142abc501..f1c27bbc02 100644
--- a/pkg/chartRepo/ChartRepositoryService.go
+++ b/pkg/chartRepo/ChartRepositoryService.go
@@ -25,7 +25,6 @@ import (
 	util3 "github.com/devtron-labs/common-lib/utils/k8s"
 	"io"
 	"io/ioutil"
-	v1 "k8s.io/api/batch/v1"
 	"net/http"
 	"net/url"
 	"strings"
@@ -712,17 +711,9 @@ func (impl *ChartRepositoryServiceImpl) TriggerChartSyncManual(chartProviderConf
 	}
 
 	manualAppSyncJobByteArr := manualAppSyncJobByteArr(impl.serverEnvConfig.AppSyncImage, impl.serverEnvConfig.AppSyncJobResourcesObj, chartProviderConfig)
-
-	var job v1.Job
-	err = yaml.Unmarshal(manualAppSyncJobByteArr, &job)
-	if err != nil {
-		impl.logger.Errorw("Unmarshal err, CreateJobSafely", "err", err)
-		return err
-	}
-
-	err = impl.K8sUtil.CreateJob(impl.aCDAuthConfig.ACDConfigMapNamespace, job.Name, defaultClusterConfig, &job)
+	err = impl.K8sUtil.DeleteAndCreateJob(manualAppSyncJobByteArr, impl.aCDAuthConfig.ACDConfigMapNamespace, defaultClusterConfig)
 	if err != nil {
-		impl.logger.Errorw("CreateJob err, CreateJobSafely", "err", err)
+		impl.logger.Errorw("DeleteAndCreateJob err, TriggerChartSyncManual", "err", err)
 		return err
 	}