chore: revert examples + add session (#1648)

Signed-off-by: Vigith Maurice <[email protected]>
numaproj · Apr 6, 2024 · 5f33361 · 5f33361
1 parent a3ca256
commit 5f33361
Show file tree

Hide file tree

Showing 9 changed files with 17 additions and 17 deletions.
diff --git a/examples/10-cycle-to-prev.yaml b/examples/10-cycle-to-prev.yaml
@@ -19,7 +19,7 @@ spec:
         container:
           # This will try each message up to 3 times before continuing, see https://github.com/numaproj/numaflow-go/tree/main/pkg/mapper/examples/retry
           # (a more realistic example might retry only on failure)
-          image: quay.io/numaio/numaflow-go/map-retry:v0.7.0-rc1
+          image: quay.io/numaio/numaflow-go/map-retry:v0.6.1
     - name: out
       scale:
         min: 1
@@ -42,4 +42,4 @@ spec:
         tags:
           operator: not
           values:
-            - retry
+            - retry
diff --git a/examples/10-cycle-to-self.yaml b/examples/10-cycle-to-self.yaml
@@ -15,7 +15,7 @@ spec:
         container:
           # This will try each message up to 3 times before continuing, see https://github.com/numaproj/numaflow-go/tree/main/pkg/mapper/examples/retry
           # (a more realistic example might retry only on failure)
-          image: quay.io/numaio/numaflow-go/map-retry:v0.7.0-rc1
+          image: quay.io/numaio/numaflow-go/map-retry:v0.6.1
     - name: out
       scale:
         min: 1
@@ -36,4 +36,4 @@ spec:
         tags:
           operator: not
           values:
-            - retry
+            - retry
diff --git a/examples/11-join-on-reduce.yaml b/examples/11-join-on-reduce.yaml
@@ -20,7 +20,7 @@ spec:
       udf:
         container:
           # Compute the sum, see https://github.com/numaproj/numaflow-go/tree/main/pkg/reducer/examples/sum
-          image: quay.io/numaio/numaflow-go/reduce-sum:v0.7.0-rc1
+          image: quay.io/numaio/numaflow-go/reduce-sum:v0.6.0
         groupBy:
           window:
             fixed:

diff --git a/examples/11-join-on-sink.yaml b/examples/11-join-on-sink.yaml
@@ -13,7 +13,7 @@ spec:
       udf:
         container:
           # Tell the input number is even or odd, see https://github.com/numaproj/numaflow-go/tree/main/pkg/mapper/examples/even_odd
-          image: quay.io/numaio/numaflow-go/map-even-odd:v0.7.0-rc1
+          image: quay.io/numaio/numaflow-go/map-even-odd:v0.6.0
     - name: even-cat
       udf:
         builtin:

diff --git a/examples/2-even-odd-pipeline.yaml b/examples/2-even-odd-pipeline.yaml
@@ -13,7 +13,7 @@ spec:
       udf:
         container:
           # Tell the input number is even or odd, see https://github.com/numaproj/numaflow-go/tree/main/pkg/mapper/examples/even_odd
-          image: quay.io/numaio/numaflow-go/map-even-odd:v0.7.0-rc1
+          image: quay.io/numaio/numaflow-go/map-even-odd:v0.6.0
     - name: even-sink
       scale:
         min: 1

diff --git a/examples/6-reduce-fixed-window-with-pvc.yaml b/examples/6-reduce-fixed-window-with-pvc.yaml
@@ -15,12 +15,12 @@ spec:
       udf:
         container:
           # Tell the input number is even or odd, see https://github.com/numaproj/numaflow-go/tree/main/pkg/mapper/examples/even_odd
-          image: quay.io/numaio/numaflow-go/map-even-odd:v0.7.0-rc1
+          image: quay.io/numaio/numaflow-go/map-even-odd:v0.6.1
     - name: compute-sum
       udf:
         container:
           # compute the sum
-          image: quay.io/numaio/numaflow-go/reduce-sum:v0.7.0-rc1
+          image: quay.io/numaio/numaflow-go/reduce-sum:stable
         groupBy:
           window:
             fixed:

diff --git a/examples/6-reduce-fixed-window.yaml b/examples/6-reduce-fixed-window.yaml
@@ -13,12 +13,12 @@ spec:
       udf:
         container:
           # Tell the input number is even or odd, see https://github.com/numaproj/numaflow-go/tree/main/pkg/mapper/examples/even_odd
-          image: quay.io/numaio/numaflow-go/map-even-odd:v0.7.0-rc1
+          image: quay.io/numaio/numaflow-go/map-even-odd:v0.6.1
     - name: compute-sum
       udf:
         container:
           # compute the sum
-          image: quay.io/numaio/numaflow-go/reduce-sum:v0.7.0-rc1
+          image: quay.io/numaio/numaflow-go/reduce-sum:v0.6.1
         groupBy:
           window:
             fixed:

diff --git a/examples/7-reduce-sliding-window.yaml b/examples/7-reduce-sliding-window.yaml
@@ -24,13 +24,13 @@ spec:
       udf:
         container:
           # Tell the input number is even or odd, see https://github.com/numaproj/numaflow-go/tree/main/pkg/mapper/examples/even_odd
-          image: quay.io/numaio/numaflow-go/map-even-odd:v0.7.0-rc1
+          image: quay.io/numaio/numaflow-go/map-even-odd:v0.6.0
     - name: reduce-sliding
       partitions: 2
       udf:
         container:
           # compute the sum
-          image: quay.io/numaio/numaflow-go/reduce-sum:v0.7.0-rc1
+          image: quay.io/numaio/numaflow-go/reduce-sum:v0.6.0
         groupBy:
           window:
             sliding:

diff --git a/examples/8-reduce-complex-pipeline.yaml b/examples/8-reduce-complex-pipeline.yaml
@@ -17,13 +17,13 @@ spec:
       udf:
         container:
           # Tell the input number is even or odd, see https://github.com/numaproj/numaflow-go/tree/main/pkg/function/examples/evenodd
-          image: quay.io/numaio/numaflow-go/map-even-odd:v0.7.0-rc1
+          image: quay.io/numaio/numaflow-go/map-even-odd:v0.6.0
     - name: keyed-fixed-sum
       partitions: 2
       udf:
         container:
           # compute the sum
-          image: quay.io/numaio/numaflow-go/reduce-sum:v0.7.0-rc1
+          image: quay.io/numaio/numaflow-go/reduce-sum:v0.6.0
         groupBy:
           window:
             fixed:
@@ -37,7 +37,7 @@ spec:
       udf:
         container:
           # compute the sum
-          image: quay.io/numaio/numaflow-go/reduce-sum:v0.7.0-rc1
+          image: quay.io/numaio/numaflow-go/reduce-sum:v0.6.0
         groupBy:
           window:
             fixed:
@@ -51,7 +51,7 @@ spec:
       udf:
         container:
           # compute the sum
-          image: quay.io/numaio/numaflow-go/reduce-sum:v0.7.0-rc1
+          image: quay.io/numaio/numaflow-go/reduce-sum:v0.6.0
         groupBy:
           window:
             sliding: