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

[tsato]

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 <subhasmitaswain...@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 {