Remove TempestRegexp argument

api/bases/test.openstack.org_tempests.yaml

@@ -35,11 +35,6 @@ spec:
           spec:
             description: TempestSpec defines the desired state of Tempest
             properties:
-              allowedTests:
-                description: AllowedTests
-                items:
-                  type: string
-                type: array
               backoffLimit:
                 default: 0
                 description: BackoffLimimt allows to define the maximum number of
@@ -114,14 +109,30 @@ spec:
                 description: OpenStackConfigSecret is the name of the Secret containing
                   the secure.yaml
                 type: string
-              skippedTests:
-                description: SkippedTests
-                items:
-                  type: string
-                type: array
-              tempestRegex:
-                description: TempestRegex
-                type: string
+              tempestRun:
+                description: TempestSpec TempestRun parts
+                properties:
+                  allowedTests:
+                    default:
+                    - tempest.api.identity.v3
+                    description: AllowedTests
+                    items:
+                      type: string
+                    type: array
+                  concurrency:
+                    default: 0
+                    description: Concurrency is the Default concurrency
+                    format: int64
+                    type: integer
+                  skippedTests:
+                    description: SkippedTests
+                    items:
+                      type: string
+                    type: array
+                  workerFile:
+                    description: WorkerFile is the detailed concurry spec file
+                    type: string
+                type: object
             required:
             - containerImage
             - openStackConfigMap

api/v1beta1/tempest_types.go

@@ -35,6 +35,27 @@ type Hash struct {
 	Hash string `json:"hash,omitempty"`
 }
 
+// TempestSpec TempestRun parts
+type TempestRunSpec struct {
+	// +kubebuilder:validation:Optional
+	// +kubebuilder:default={"tempest.api.identity.v3"}
+	// AllowedTests
+	AllowedTests []string `json:"allowedTests,omitempty"`
+
+	// +kubebuilder:validation:Optional
+	// SkippedTests
+	SkippedTests []string `json:"skippedTests,omitempty"`
+
+        // +kubebuilder:validation:Optional
+	// +kubebuilder:default:=0
+        // Concurrency is the Default concurrency
+        Concurrency *int64 `json:"concurrency,omitempty"`
+
+        // +kubebuilder:validation:Optional
+        // WorkerFile is the detailed concurry spec file
+        WorkerFile string `json:"workerFile,omitempty"`
+}
+
 // TempestSpec defines the desired state of Tempest
 type TempestSpec struct {
 	// +kubebuilder:validation:Required
@@ -63,26 +84,18 @@ type TempestSpec struct {
 	// ExternalEndpoints, expose a VIP using a pre-created IPAddressPool
 	ExternalEndpoints []MetalLBConfig `json:"externalEndpoints,omitempty"`
 
-	// +kubebuilder:validation:Optional
-	// TempestRegex
-	TempestRegex string `json:"tempestRegex,omitempty"`
-
-	// +kubebuilder:validation:Optional
-	// AllowedTests
-	AllowedTests []string `json:"allowedTests,omitempty"`
-
-	// +kubebuilder:validation:Optional
-	// SkippedTests
-	SkippedTests []string `json:"skippedTests,omitempty"`
-
 	// BackoffLimimt allows to define the maximum number of retried executions (defaults to 6).
 	// +kubebuilder:default:=0
 	// +operator-sdk:csv:customresourcedefinitions:type=spec,xDescriptors={"urn:alm:descriptor:com.tectonic.ui:number"}
 	BackoffLimit *int32 `json:"backoffLimit,omitempty"`
 
+	// +kubebuilder:validation:Optional
+        TempestRun *TempestRunSpec `json:"tempestRun,omitempty"`
+
 	// TODO(slaweq): add more tempest run parameters here
 }
 
+
 // MetalLBConfig to configure the MetalLB loadbalancer service
 type MetalLBConfig struct {
 	// +kubebuilder:validation:Required

config/crd/bases/test.openstack.org_tempests.yaml

@@ -35,11 +35,6 @@ spec:
           spec:
             description: TempestSpec defines the desired state of Tempest
             properties:
-              allowedTests:
-                description: AllowedTests
-                items:
-                  type: string
-                type: array
               backoffLimit:
                 default: 0
                 description: BackoffLimimt allows to define the maximum number of
@@ -114,14 +109,30 @@ spec:
                 description: OpenStackConfigSecret is the name of the Secret containing
                   the secure.yaml
                 type: string
-              skippedTests:
-                description: SkippedTests
-                items:
-                  type: string
-                type: array
-              tempestRegex:
-                description: TempestRegex
-                type: string
+              tempestRun:
+                description: TempestSpec TempestRun parts
+                properties:
+                  allowedTests:
+                    default:
+                    - tempest.api.identity.v3
+                    description: AllowedTests
+                    items:
+                      type: string
+                    type: array
+                  concurrency:
+                    default: 0
+                    description: Concurrency is the Default concurrency
+                    format: int64
+                    type: integer
+                  skippedTests:
+                    description: SkippedTests
+                    items:
+                      type: string
+                    type: array
+                  workerFile:
+                    description: WorkerFile is the detailed concurry spec file
+                    type: string
+                type: object
             required:
             - containerImage
             - openStackConfigMap

config/samples/test_v1beta1_tempest.yaml

@@ -5,4 +5,7 @@ metadata:
   namespace: openstack
 spec:
   containerImage: quay.io/podified-antelope-centos9/openstack-tempest:current-podified
-  secret: tempest-secret
+  tempestRun:
+    allowedTests:
+      - tempest.api.identity.v3.*
+    concurrency: 8

controllers/tempest_controller.go

@@ -385,9 +385,14 @@ func (r *TempestReconciler) generateServiceConfigMaps(
 	cmLabels := labels.GetLabels(instance, labels.GetGroupLabel(tempest.ServiceName), map[string]string{})
 
 	templateParameters := make(map[string]interface{})
+	customData := make(map[string]string)
 
-	templateParameters["AllowedTests"] = instance.Spec.AllowedTests
-	templateParameters["SkippedTests"] = instance.Spec.SkippedTests
+	if len(instance.Spec.TempestRun.WorkerFile) != 0 {
+		customData["worker_file.yaml"] = instance.Spec.TempestRun.WorkerFile
+	}
+
+	templateParameters["AllowedTests"] = instance.Spec.TempestRun.AllowedTests
+	templateParameters["SkippedTests"] = instance.Spec.TempestRun.SkippedTests
 
 	cms := []util.Template{
 		// ScriptsConfigMap
@@ -406,6 +411,7 @@ func (r *TempestReconciler) generateServiceConfigMaps(
 			InstanceType:  instance.Kind,
 			Labels:        cmLabels,
 			ConfigOptions: templateParameters,
+			CustomData:    customData,
 		},
 	}
 	return configmap.EnsureConfigMaps(ctx, h, instance, cms, nil)

pkg/tempest/job.go

@@ -7,6 +7,7 @@ import (
 	batchv1 "k8s.io/api/batch/v1"
 	corev1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"strconv"
 )
 
 // Job - prepare job to run Tempest tests
@@ -18,13 +19,10 @@ func Job(
 	envVars := map[string]env.Setter{}
 	runAsUser := int64(42480)
 	runAsGroup := int64(42480)
-
-	args := []string{
-		"/var/lib/tempest/run_tempest.sh",
-	}
-	if instance.Spec.TempestRegex != "" {
-		args = append(args, "--regex")
-		args = append(args, instance.Spec.TempestRegex)
+	if instance.Spec.TempestRun.Concurrency != nil {
+		envVars["TEMPEST_CONCURRENCY"] = env.SetValue(strconv.FormatInt(*instance.Spec.TempestRun.Concurrency, 10))
+	} else {
+		envVars["TEMPEST_CONCURRENCY"] = env.SetValue("0")
 	}
 
 	job := &batchv1.Job{
@@ -40,9 +38,9 @@ func Job(
 					RestartPolicy:      corev1.RestartPolicyNever,
 					ServiceAccountName: instance.RbacResourceName(),
 					SecurityContext: &corev1.PodSecurityContext{
-						RunAsUser: &runAsUser,
+						RunAsUser:  &runAsUser,
 						RunAsGroup: &runAsGroup,
-						FSGroup: &runAsGroup,
+						FSGroup:    &runAsGroup,
 					},
 					Containers: []corev1.Container{
 						{
@@ -51,7 +49,7 @@ func Job(
 							Command: []string{
 								"/usr/local/bin/container-scripts/invoke_tempest",
 							},
-							Args: []string{},
+							Args:         []string{},
 							Env:          env.MergeEnvs([]corev1.EnvVar{}, envVars),
 							VolumeMounts: GetVolumeMounts(),
 						},

templates/tempest/bin/invoke_tempest

@@ -18,9 +18,14 @@ cd "$TEMPEST_DIR"
 # TODO: consider profile support, deployer-input and other args passing
 discover-tempest-config --os-cloud "$OS_CLOUD" --debug --create identity.v3_endpoint_type public
 
+if [ -e $OPERATOR_ETC/worker_file.yaml ]; then
+    WORKER_FILE="--worker-file $OPERATOR_ETC/worker_file.yaml"
+fi
+
 tempest run \
-    --include-list ${OPERATOR_ETC}/include.txt \
-    --exclude-list ${OPERATOR_ETC}/exclude.txt
+    --concurrency "${TEMPEST_CONCURRENCY}" $WORKER_FILE \
+    --include-list "${OPERATOR_ETC}/include.txt" \
+    --exclude-list "${OPERATOR_ETC}/exclude.txt"
 
 # NOTE: We might not want to fail when tests are executed
 RETURN_VALUE=$?

templates/tempest/config/include.txt

@@ -1,5 +1,3 @@
 {{range $val := .AllowedTests }}
 {{$val}}
-{{ else }}
-tempest.api.identity.v3
 {{end}}