feat: support skipping initializer in testrun spec

Author: Kristina-Pianykh

api/v1alpha1/testrun_types.go

@@ -32,6 +32,9 @@ type PodMetadata struct {
 }
 
 type Pod struct {
+	// +optional
+	// +kubebuilder:default=false
+	Disabled                     bool                              `json:"disabled"`
 	Affinity                     *corev1.Affinity                  `json:"affinity,omitempty"`
 	AutomountServiceAccountToken string                            `json:"automountServiceAccountToken,omitempty"`
 	Env                          []corev1.EnvVar                   `json:"env,omitempty"`
@@ -293,3 +296,10 @@ func (k6 *TestRun) ListOptions() *client.ListOptions {
 
 	return &client.ListOptions{LabelSelector: selector, Namespace: k6.NamespacedName().Namespace}
 }
+
+func (k6 *TestRun) IsInitializerDisabled() bool {
+	if k6.GetSpec().Initializer == nil {
+		return false
+	}
+	return k6.GetSpec().Initializer.Disabled == true
+}

config/crd/bases/k6.io_testruns.yaml

@@ -558,6 +558,9 @@ spec:
                             type: string
                         type: object
                     type: object
+                  disable:
+                    default: false
+                    type: boolean
                   env:
                     items:
                       properties:
@@ -2593,6 +2596,9 @@ spec:
                             type: string
                         type: object
                     type: object
+                  disable:
+                    default: false
+                    type: boolean
                   env:
                     items:
                       properties:
@@ -4649,6 +4655,9 @@ spec:
                             type: string
                         type: object
                     type: object
+                  disable:
+                    default: false
+                    type: boolean
                   env:
                     items:
                       properties:

config/samples/k6_v1alpha1_testrun_initializer_disabled.yaml

@@ -0,0 +1,13 @@
+---
+apiVersion: k6.io/v1alpha1
+kind: TestRun
+metadata:
+  name: k6-sample
+spec:
+  parallelism: 4
+  initializer:
+    disabled: true
+  script:
+    configMap:
+      name: k6-test
+      file: test.js

docs/crd-generated.md

@@ -869,6 +869,15 @@ Some fields are present in both SecurityContext and PodSecurityContext.  When bo
 are set, the values in SecurityContext take precedence.<br/>
         </td>
         <td>false</td>
+      </tr><tr>
+        <td><b>disabled</b></td>
+        <td>boolean</td>
+        <td>
+          <br/>
+          <br/>
+            <i>Default</i>: false<br/>
+        </td>
+        <td>false</td>
       </tr><tr>
         <td><b><a href="#testrunspecinitializerenvindex">env</a></b></td>
         <td>[]object</td>
@@ -9822,6 +9831,15 @@ Some fields are present in both SecurityContext and PodSecurityContext.  When bo
 are set, the values in SecurityContext take precedence.<br/>
         </td>
         <td>false</td>
+      </tr><tr>
+        <td><b>disabled</b></td>
+        <td>boolean</td>
+        <td>
+          <br/>
+          <br/>
+            <i>Default</i>: false<br/>
+        </td>
+        <td>false</td>
       </tr><tr>
         <td><b><a href="#testrunspecrunnerenvindex">env</a></b></td>
         <td>[]object</td>
@@ -18797,6 +18815,15 @@ Some fields are present in both SecurityContext and PodSecurityContext.  When bo
 are set, the values in SecurityContext take precedence.<br/>
         </td>
         <td>false</td>
+      </tr><tr>
+        <td><b>disabled</b></td>
+        <td>boolean</td>
+        <td>
+          <br/>
+          <br/>
+            <i>Default</i>: false<br/>
+        </td>
+        <td>false</td>
       </tr><tr>
         <td><b><a href="#testrunspecstarterenvindex">env</a></b></td>
         <td>[]object</td>

internal/controller/testrun_controller.go

@@ -140,6 +140,24 @@ func (r *TestRunReconciler) reconcile(ctx context.Context, req ctrl.Request, log
 			return ctrl.Result{}, err
 		}
 
+		// Not a clout test and initializer is set to disabled
+		// -> skip creating initializer job
+		if !isCloudTestRun(k6) && k6.IsInitializerDisabled() {
+			log.Info("Initializer is disabled, skipping initialization step")
+			v1alpha1.UpdateCondition(k6, v1alpha1.InitializerSkipped, metav1.ConditionTrue)
+			v1alpha1.UpdateCondition(k6, v1alpha1.CloudTestRun, metav1.ConditionFalse)
+			v1alpha1.UpdateCondition(k6, v1alpha1.CloudPLZTestRun, metav1.ConditionFalse)
+
+			log.Info("Changing stage of TestRun status to initialized")
+
+			k6.GetStatus().Stage = "initialized"
+			if updateHappened, err := r.UpdateStatus(ctx, k6, log); err != nil {
+				return ctrl.Result{}, err
+			} else if updateHappened {
+				return ctrl.Result{}, nil
+			}
+		}
+
 		log.Info("Changing stage of TestRun status to initialization")
 		k6.GetStatus().Stage = "initialization"