From 476d4165f6e9d1df52d00f17b0e9ea3726e0bdc8 Mon Sep 17 00:00:00 2001 From: Kevin Su Date: Tue, 29 Aug 2023 18:50:08 -0700 Subject: [PATCH] fixing max parallelism (#611) Signed-off-by: Kevin Su --- pkg/controller/nodes/task/handler.go | 6 ------ 1 file changed, 6 deletions(-) diff --git a/pkg/controller/nodes/task/handler.go b/pkg/controller/nodes/task/handler.go index 1cffebb80..d2d2107db 100644 --- a/pkg/controller/nodes/task/handler.go +++ b/pkg/controller/nodes/task/handler.go @@ -578,9 +578,6 @@ func (t Handler) Handle(ctx context.Context, nCtx interfaces.NodeExecutionContex return handler.UnknownTransition, errors.Wrapf(errors.RuntimeExecutionError, nCtx.NodeID(), err, "failed during plugin execution") } if pluginTrns.IsPreviouslyObserved() { - if !pluginTrns.pInfo.Phase().IsTerminal() { - logger.Infof(ctx, "Parallelism now set to [%d].", nCtx.ExecutionContext().IncrementParallelism()) - } logger.Debugf(ctx, "No state change for Task, previously observed same transition. Short circuiting.") return pluginTrns.FinalTransition(ctx) } @@ -667,9 +664,6 @@ func (t Handler) Handle(ctx context.Context, nCtx interfaces.NodeExecutionContex return handler.UnknownTransition, err } - if !pluginTrns.pInfo.Phase().IsTerminal() { - logger.Infof(ctx, "Parallelism now set to [%d].", nCtx.ExecutionContext().IncrementParallelism()) - } return pluginTrns.FinalTransition(ctx) }