Method killContainers

workflow/executor/executor.go:1348–1355

(ctx context.Context, containerNames []string)

}

func (we *WorkflowExecutor) killContainers(ctx context.Context, containerNames []string) {
	logger := logging.RequireLoggerFromContext(ctx)
	logger.WithField("containerNames", containerNames).Info(ctx, "Killing containers")
	terminationGracePeriodDuration := GetTerminationGracePeriodDuration()
	if err := we.RuntimeExecutor.Kill(ctx, containerNames, terminationGracePeriodDuration); err != nil {
		logger.WithField("containerNames", containerNames).WithError(err).Warn(ctx, "Failed to kill")
	}
}

func (we *WorkflowExecutor) Init() error {
	if i, ok := we.RuntimeExecutor.(Initializer); ok {