Skip to content
Open
Changes from 1 commit
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
28 changes: 19 additions & 9 deletions pkg/build/trigger/HandlerService.go
Original file line number Diff line number Diff line change
Expand Up @@ -89,10 +89,10 @@ type HandlerService interface {

// CATEGORY=CI_BUILDX
type BuildxGlobalFlags struct {
BuildxCacheModeMin bool `env:"BUILDX_CACHE_MODE_MIN" envDefault:"false" description:"To set build cache mode to minimum in buildx" `
AsyncBuildxCacheExport bool `env:"ASYNC_BUILDX_CACHE_EXPORT" envDefault:"false" description:"To enable async container image cache export"`
BuildxInterruptionMaxRetry int `env:"BUILDX_INTERRUPTION_MAX_RETRY" envDefault:"3" description:"Maximum number of retries for buildx builder interruption"`
BuildxBuilderPodWaitDurationSecs int `env:"BUILDX_BUILDER_POD_WAIT_DURATION_SECS" envDefault:"120" description:"Timeout in seconds to wait for buildx k8s driver builder pods to be ready (initial startup and after spot interruption)"`
BuildxCacheModeMin bool `env:"BUILDX_CACHE_MODE_MIN" envDefault:"false" description:"To set build cache mode to minimum in buildx" `
AsyncBuildxCacheExport bool `env:"ASYNC_BUILDX_CACHE_EXPORT" envDefault:"false" description:"To enable async container image cache export"`
BuildxInterruptionMaxRetry int `env:"BUILDX_INTERRUPTION_MAX_RETRY" envDefault:"3" description:"Maximum number of retries for buildx builder interruption"`
BuildxBuilderPodWaitDurationSecs int `env:"BUILDX_BUILDER_POD_WAIT_DURATION_SECS" envDefault:"120" description:"Timeout in seconds to wait for buildx k8s driver builder pods to be ready (initial startup and after spot interruption)"`
}

type HandlerServiceImpl struct {
Expand Down Expand Up @@ -916,14 +916,24 @@ func (impl *HandlerServiceImpl) getEnvironmentForJob(pipeline *pipelineConfig.Ci
isJob := false
if app.AppType == helper.Job {
isJob = true
if trigger.EnvironmentId != 0 {
env, err = impl.envRepository.FindById(trigger.EnvironmentId)
if err != nil {
impl.Logger.Errorw("could not find environment", "err", err)
if trigger.EnvironmentId == 0 {
ciEnvMapping, err := impl.ciPipelineRepository.FindCiEnvMappingByCiPipelineId(trigger.EnvironmentId)
if err != nil && !util.IsErrNoRows(err) {
impl.Logger.Errorw("error in saving pipeline", "pipelineId", pipeline.Id, "err", err)
return nil, isJob, err
}
return env, isJob, nil
if ciEnvMapping != nil {
trigger.EnvironmentId = ciEnvMapping.EnvironmentId
}
}

env, err = impl.envRepository.FindById(trigger.EnvironmentId)
if err != nil {
impl.Logger.Errorw("could not find environment", "err", err)
return nil, isJob, err
}

return env, isJob, nil
}
return nil, isJob, nil
}
Expand Down
Loading