Skip to content
Merged
Show file tree
Hide file tree
Changes from 2 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions pkg/app/AppService.go
Original file line number Diff line number Diff line change
Expand Up @@ -155,6 +155,7 @@ type AppService interface {
MarkImageScanDeployed(appId int, envId int, imageDigest string, clusterId int) error
GetChartRepoName(gitRepoUrl string) string
UpdateDeploymentStatusForGitOpsCdPipelines(app *v1alpha1.Application, statusTime time.Time) (bool, bool, error)
WriteCDSuccessEvent(appId int, envId int, override *chartConfig.PipelineOverride)
}

func NewAppService(
Expand Down
1 change: 1 addition & 0 deletions pkg/pipeline/CdHandler.go
Original file line number Diff line number Diff line change
Expand Up @@ -317,6 +317,7 @@ func (impl *CdHandlerImpl) CheckHelmAppStatusPeriodicallyAndUpdateInDb(timeForDe
}
impl.Logger.Infow("updating workflow runner status for helm app", "cdWf", cdWf)
if cdWf.Status == application.Healthy {
go impl.appService.WriteCDSuccessEvent(pipelineOverride.Pipeline.AppId, pipelineOverride.Pipeline.EnvironmentId, pipelineOverride)
err = impl.workflowDagExecutor.HandleDeploymentSuccessEvent("", pipelineOverride.Id)
if err != nil {
impl.Logger.Errorw("error on handling deployment success event", "cdWf", cdWf, "err", err)
Expand Down
1 change: 1 addition & 0 deletions pkg/pipeline/WebhookService.go
Original file line number Diff line number Diff line change
Expand Up @@ -206,6 +206,7 @@ func (impl WebhookServiceImpl) HandleCiSuccessEvent(ciPipelineId int, request *C
}
}
ciArtifactArr = append(ciArtifactArr, artifact)
go impl.WriteCISuccessEvent(request, pipeline, artifact)
isCiManual := true
if request.UserId == 1 {
impl.logger.Debugw("Trigger (auto) by system user", "userId", request.UserId)
Expand Down