You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ts...@apache.org on 2022/06/23 09:28:27 UTC

[camel-k] branch main updated: introduce spectrum option job

This is an automated email from the ASF dual-hosted git repository.

tsato pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-k.git


The following commit(s) were added to refs/heads/main by this push:
     new 8c50824ad introduce spectrum option job
8c50824ad is described below

commit 8c50824ada5f55fbc97d87b7ac7fe517f79bed24
Author: Subhasmita Swain <su...@gmail.com>
AuthorDate: Thu Jun 16 17:45:53 2022 +0530

    introduce spectrum option job
---
 go.sum                  | 1 -
 pkg/builder/spectrum.go | 5 +++++
 2 files changed, 5 insertions(+), 1 deletion(-)

diff --git a/go.sum b/go.sum
index 520c4ff6f..711cdf2a0 100644
--- a/go.sum
+++ b/go.sum
@@ -310,7 +310,6 @@ github.com/containerd/containerd v1.5.0-beta.1/go.mod h1:5HfvG1V2FsKesEGQ17k5/T7
 github.com/containerd/containerd v1.5.0-beta.3/go.mod h1:/wr9AVtEM7x9c+n0+stptlo/uBBoBORwEx6ardVcmKU=
 github.com/containerd/containerd v1.5.0-beta.4/go.mod h1:GmdgZd2zA2GYIBZ0w09ZvgqEq8EfBp/m3lcVZIvPHhI=
 github.com/containerd/containerd v1.5.0-rc.0/go.mod h1:V/IXoMqNGgBlabz3tHD2TWDoTJseu1FGOKuoA4nNb2s=
-github.com/containerd/containerd v1.5.8 h1:NmkCC1/QxyZFBny8JogwLpOy2f+VEbO/f6bV2Mqtwuw=
 github.com/containerd/containerd v1.5.8/go.mod h1:YdFSv5bTFLpG2HIYmfqDpSYYTDX+mc5qtSuYx1YUb/s=
 github.com/containerd/continuity v0.0.0-20190426062206-aaeac12a7ffc/go.mod h1:GL3xCUCBDV3CZiTSEKksMWbLE66hEyuu9qyDOOqM47Y=
 github.com/containerd/continuity v0.0.0-20190815185530-f2a389ac0a02/go.mod h1:GL3xCUCBDV3CZiTSEKksMWbLE66hEyuu9qyDOOqM47Y=
diff --git a/pkg/builder/spectrum.go b/pkg/builder/spectrum.go
index 5aedbf488..bcfac8e3f 100644
--- a/pkg/builder/spectrum.go
+++ b/pkg/builder/spectrum.go
@@ -25,6 +25,7 @@ import (
 	"os"
 	"path"
 	"path/filepath"
+	"runtime"
 	"strings"
 
 	"go.uber.org/multierr"
@@ -126,6 +127,10 @@ func (t *spectrumTask) Do(ctx context.Context) v1.BuildStatus {
 		Recursive:     true,
 	}
 
+	if jobs := runtime.GOMAXPROCS(0); jobs > 1 {
+		options.Jobs = jobs
+	}
+
 	go readSpectrumLogs(newStdR)
 	digest, err := spectrum.Build(options, contextDir+":"+path.Join(DeploymentDir))
 	if err != nil {