public_git
/
helmfile
mirror of https://github.com/helmfile/helmfile.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

fix unexpectedly high concurrency since the dag support

This commit is contained in:
Yusuke Kuoka 2019-10-28 13:25:25 +09:00
parent 88caa7514f
commit fc0a7b68a8
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
pkg/state/state.go
View File

@ -459,7 +459,7 @@ func (st *HelmState) SyncReleases(affectedReleases *AffectedReleases, helm helme
st.logger.Debugf("syncing releases in group %d/%d: %s", groupIndex+1, groupsTotal, strings.Join(idsInGroup, ", "))
errs := st.syncReleaseGroup(affectedReleases, helm, prepsInGroup)
errs := st.syncReleaseGroup(affectedReleases, helm, workerLimit, prepsInGroup)
if len(errs) > 0 {
return errs
}
@ -486,11 +486,15 @@ func releaseToID(r *ReleaseSpec) string {
return id
}
func (st *HelmState) syncReleaseGroup(affectedReleases *AffectedReleases, helm helmexec.Interface, preps []syncPrepareResult) []error {
func (st *HelmState) syncReleaseGroup(affectedReleases *AffectedReleases, helm helmexec.Interface, concurrency int, preps []syncPrepareResult) []error {
errs := []error{}
jobQueue := make(chan *syncPrepareResult, len(preps))
results := make(chan syncResult, len(preps))
concurrency := len(preps)
if concurrency == 0 {
concurrency = len(preps)
}
m := new(sync.Mutex)
st.scatterGather(
concurrency,