From 1cd5f239250e44af8b4732d820135f92d8c7aefc Mon Sep 17 00:00:00 2001 From: Radek Simko Date: Tue, 4 Jan 2022 14:21:51 +0000 Subject: [PATCH] Reduce parallelism to 1/1 in all cases --- internal/terraform/module/module_loader.go | 31 ++-------------------- 1 file changed, 2 insertions(+), 29 deletions(-) diff --git a/internal/terraform/module/module_loader.go b/internal/terraform/module/module_loader.go index dfb5fa859..424cb6d3f 100644 --- a/internal/terraform/module/module_loader.go +++ b/internal/terraform/module/module_loader.go @@ -3,7 +3,6 @@ package module import ( "context" "log" - "runtime" "sync/atomic" "time" @@ -30,13 +29,12 @@ type moduleLoader struct { } func newModuleLoader(fs filesystem.Filesystem, modStore *state.ModuleStore, schemaStore *state.ProviderSchemaStore) *moduleLoader { - p := loaderParallelism(runtime.NumCPU()) plc, lc := int64(0), int64(0) ml := &moduleLoader{ queue: newModuleOpsQueue(fs), logger: defaultLogger, - nonPrioParallelism: p.NonPriority, - prioParallelism: p.Priority, + nonPrioParallelism: 1, + prioParallelism: 1, opsToDispatch: make(chan ModuleOperation, 1), loadingCount: &lc, prioLoadingCount: &plc, @@ -48,31 +46,6 @@ func newModuleLoader(fs filesystem.Filesystem, modStore *state.ModuleStore, sche return ml } -type parallelism struct { - NonPriority, Priority int64 -} - -func loaderParallelism(cpu int) parallelism { - // Cap utilization for powerful machines - if cpu >= 4 { - return parallelism{ - NonPriority: int64(3), - Priority: int64(1), - } - } - if cpu == 3 { - return parallelism{ - NonPriority: int64(2), - Priority: int64(1), - } - } - - return parallelism{ - NonPriority: 1, - Priority: 1, - } -} - func (ml *moduleLoader) SetLogger(logger *log.Logger) { ml.logger = logger }