fix: cron parser uses 6 field format (#3068)

Signed-off-by: Vigith Maurice <[email protected]>

Author: vigith

docs/specifications/side-inputs.md

@@ -111,7 +111,7 @@ spec:
       container:
         image: my-sideinputs-image:v1
       trigger:
-        schedule: "*/15 * * * *"
+        schedule: "0 */15 * * * *"
         # interval: 180s
         # timezone: America/Los_Angeles
   vertices:

docs/user-guide/reference/side-inputs.md

@@ -22,13 +22,13 @@ spec:
       container:
         image: my-sideinputs-s3-image:v1
       trigger:
-        schedule: "*/15 * * * *"
+        schedule: "0 */15 * * * *"
         # timezone: America/Los_Angeles
     - name: redis
       container:
         image: my-sideinputs-redis-image:v1
       trigger:
-        schedule: "*/15 * * * *"
+        schedule: "0 */15 * * * *"
         # timezone: America/Los_Angeles
   vertices:
     - name: my-vertex

pkg/reconciler/pipeline/controller_test.go

@@ -971,7 +971,7 @@ func Test_createOrUpdateSIMDeployments(t *testing.T) {
 					Image: "test",
 				},
 				Trigger: &dfv1.SideInputTrigger{
-					Schedule: "1 * * * *",
+					Schedule: "0 1 * * * *",
 				},
 			},
 		}
@@ -993,7 +993,7 @@ func Test_createOrUpdateSIMDeployments(t *testing.T) {
 					Image: "test",
 				},
 				Trigger: &dfv1.SideInputTrigger{
-					Schedule: "1 * * * *",
+					Schedule: "0 1 * * * *",
 				},
 			},
 			{
@@ -1002,7 +1002,7 @@ func Test_createOrUpdateSIMDeployments(t *testing.T) {
 					Image: "test",
 				},
 				Trigger: &dfv1.SideInputTrigger{
-					Schedule: "1 * * * *",
+					Schedule: "0 1 * * * *",
 				},
 			},
 		}
@@ -1025,7 +1025,7 @@ func Test_createOrUpdateSIMDeployments(t *testing.T) {
 					Image: "test",
 				},
 				Trigger: &dfv1.SideInputTrigger{
-					Schedule: "1 * * * *",
+					Schedule: "0 1 * * * *",
 				},
 			},
 		}

pkg/reconciler/vertex/controller_test.go

@@ -689,7 +689,7 @@ func Test_reconcile(t *testing.T) {
 					Image: "test",
 				},
 				Trigger: &dfv1.SideInputTrigger{
-					Schedule: "1 * * * *",
+					Schedule: "0 1 * * * *",
 				},
 			},
 		}

test/sideinputs-e2e/testdata/map-sideinput-pipeline.yaml

@@ -10,7 +10,7 @@ spec:
         image: quay.io/numaio/numaflow-go/map-sideinput:stable
         imagePullPolicy: IfNotPresent
       trigger:
-        schedule: "*/5 * * * * *"
+        schedule: "0 */5 * * * *"
   vertices:
     - name: in
       limits:

test/sideinputs-e2e/testdata/reduce-sideinput-pipeline.yaml

@@ -13,7 +13,7 @@ spec:
         image: quay.io/numaio/numaflow-go/reduce-sideinput:stable
         imagePullPolicy: IfNotPresent
       trigger:
-        schedule: "*/5 * * * * *"
+        schedule: "0 */5 * * * *"
   vertices:
     - name: in
       limits:

test/sideinputs-e2e/testdata/sideinput-sink.yaml

@@ -10,7 +10,7 @@ spec:
         image: quay.io/numaio/numaflow-go/sideinput-function:stable
         imagePullPolicy: IfNotPresent
       trigger:
-        schedule: "*/5 * * * * *"
+        schedule: "0 */5 * * * *"
         # timezone: America/Los_Angeles
   vertices:
     - name: in

test/sideinputs-e2e/testdata/sideinput-source.yaml

@@ -10,7 +10,7 @@ spec:
         image: quay.io/numaio/numaflow-go/sideinput-function:stable
         imagePullPolicy: IfNotPresent
       trigger:
-        schedule: "*/5 * * * * *"
+        schedule: "0 */5 * * * *"
         # timezone: America/Los_Angeles
   vertices:
     - name: in

ui/src/components/pages/Pipeline/partials/Graph/index.test.tsx

@@ -292,7 +292,7 @@ const mockData: GraphData = {
             imagePullPolicy: "Always",
           },
           trigger: {
-            schedule: "*/2 * * * *",
+            schedule: "0 */2 * * * *",
             timezone: null,
           },
         },
@@ -411,7 +411,7 @@ const mockData: GraphData = {
             imagePullPolicy: "Always",
           },
           trigger: {
-            schedule: "*/2 * * * *",
+            schedule: "0 */2 * * * *",
             timezone: null,
           },
         },

ui/src/components/pages/Pipeline/partials/Graph/partials/NodeInfo/index.test.tsx

@@ -74,7 +74,7 @@ describe("NodeInfo", () => {
           imagePullPolicy: "Always",
         },
         trigger: {
-          schedule: "*/2 * * * *",
+          schedule: "0 */2 * * * *",
           timezone: null,
         },
       },