fixing max parallelism (#611)

Signed-off-by: Kevin Su <pingsutw@apache.org>
flyteorg · Aug 30, 2023 · 476d416 · 476d416
1 parent ebc0ae7
commit 476d416
Showing 1 changed file with 0 additions and 6 deletions.
diff --git 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)
 }