chore: update example image tags to use stable (#1594)

Signed-off-by: a3hadi <[email protected]>
numaproj · Mar 22, 2024 · e857344 · e857344
1 parent 04ff0c6
commit e857344
Show file tree

Hide file tree

Showing 27 changed files with 54 additions and 54 deletions.
diff --git a/test/diamond-e2e/testdata/cycle-backward.yaml b/test/diamond-e2e/testdata/cycle-backward.yaml
@@ -17,7 +17,7 @@ spec:
       udf:
         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
-          image: quay.io/numaio/numaflow-go/map-retry:v0.6.1
+          image: quay.io/numaio/numaflow-go/map-retry:stable
     - name: out
       sink:
         udsink:

diff --git a/test/diamond-e2e/testdata/cycle-to-self.yaml b/test/diamond-e2e/testdata/cycle-to-self.yaml
@@ -13,7 +13,7 @@ spec:
       udf:
         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
-          image: quay.io/numaio/numaflow-go/map-retry:v0.6.1
+          image: quay.io/numaio/numaflow-go/map-retry:stable
     - name: out
       sink:
         udsink:

diff --git a/test/diamond-e2e/testdata/join-on-reduce-pipeline.yaml b/test/diamond-e2e/testdata/join-on-reduce-pipeline.yaml
@@ -17,21 +17,21 @@ 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.6.1
+          image: quay.io/numaio/numaflow-go/map-even-odd:stable
     - name: atoi-1
       partitions: 2
       scale:
         min: 1
       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.6.1
+          image: quay.io/numaio/numaflow-go/map-even-odd:stable
     - name: compute-sum
       partitions: 2
       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.6.1
+          image: quay.io/numaio/numaflow-go/reduce-sum:stable
         groupBy:
           window:
             fixed:

diff --git a/test/diamond-e2e/testdata/join-on-sink.yaml b/test/diamond-e2e/testdata/join-on-sink.yaml
@@ -11,7 +11,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.6.1
+          image: quay.io/numaio/numaflow-go/map-even-odd:stable
     - name: even-cat
       udf:
         builtin:

diff --git a/test/e2e/testdata/even-odd.yaml b/test/e2e/testdata/even-odd.yaml
@@ -12,7 +12,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.6.1
+          image: quay.io/numaio/numaflow-go/map-even-odd:stable
     - name: even-sink
       partitions: 2
       sink:

diff --git a/test/idle-source-e2e/testdata/idle-source-reduce-pipeline.yaml b/test/idle-source-e2e/testdata/idle-source-reduce-pipeline.yaml
@@ -23,13 +23,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.6.1
+          image: quay.io/numaio/numaflow-go/map-even-odd:stable
     - name: compute-sum
       partitions: 2
       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.6.1
+          image: quay.io/numaio/numaflow-go/reduce-sum:stable
         groupBy:
           window:
             fixed:

diff --git a/test/idle-source-e2e/testdata/kafka-pipeline.yaml b/test/idle-source-e2e/testdata/kafka-pipeline.yaml
@@ -29,7 +29,7 @@ spec:
     - name: count-event
       udf:
         container:
-          image: quay.io/numaio/numaflow-go/reduce-counter:v0.6.1
+          image: quay.io/numaio/numaflow-go/reduce-counter:stable
         groupBy:
           window:
             fixed:

diff --git a/test/reduce-one-e2e/testdata/complex-reduce-pipeline.yaml b/test/reduce-one-e2e/testdata/complex-reduce-pipeline.yaml
@@ -19,13 +19,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.6.1
+          image: quay.io/numaio/numaflow-go/map-even-odd:stable
     - name: keyed-fixed-sum
       partitions: 1
       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.6.1
+          image: quay.io/numaio/numaflow-go/reduce-sum:stable
         groupBy:
           window:
             fixed:
@@ -37,7 +37,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.6.1
+          image: quay.io/numaio/numaflow-go/reduce-sum:stable
         groupBy:
           window:
             fixed:

diff --git a/test/reduce-one-e2e/testdata/complex-sliding-window-pipeline.yaml b/test/reduce-one-e2e/testdata/complex-sliding-window-pipeline.yaml
@@ -19,13 +19,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.6.1
+          image: quay.io/numaio/numaflow-go/map-even-odd:stable
     - name: keyed-fixed-sum
       partitions: 2
       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.6.1
+          image: quay.io/numaio/numaflow-go/reduce-sum:stable
         groupBy:
           window:
             fixed:
@@ -37,7 +37,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.6.1
+          image: quay.io/numaio/numaflow-go/reduce-sum:stable
         groupBy:
           window:
             fixed:
@@ -49,7 +49,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.6.1
+          image: quay.io/numaio/numaflow-go/reduce-sum:stable
         groupBy:
           window:
             sliding:

diff --git a/test/reduce-one-e2e/testdata/simple-keyed-reduce-pipeline.yaml b/test/reduce-one-e2e/testdata/simple-keyed-reduce-pipeline.yaml
@@ -19,13 +19,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.6.1
+          image: quay.io/numaio/numaflow-go/map-even-odd:stable
     - name: compute-sum
       partitions: 1
       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.6.1
+          image: quay.io/numaio/numaflow-go/reduce-sum:stable
         groupBy:
           window:
             fixed:

diff --git a/test/reduce-one-e2e/testdata/simple-non-keyed-reduce-pipeline.yaml b/test/reduce-one-e2e/testdata/simple-non-keyed-reduce-pipeline.yaml
@@ -19,12 +19,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.6.1
+          image: quay.io/numaio/numaflow-go/map-even-odd:stable
     - name: compute-sum
       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.6.1
+          image: quay.io/numaio/numaflow-go/reduce-sum:stable
         groupBy:
           window:
             fixed:

diff --git a/test/reduce-one-e2e/testdata/simple-reduce-pipeline-wal.yaml b/test/reduce-one-e2e/testdata/simple-reduce-pipeline-wal.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/mapper/examples/even_odd
-          image: quay.io/numaio/numaflow-go/map-even-odd:v0.6.1
+          image: quay.io/numaio/numaflow-go/map-even-odd:stable
     - name: compute-sum
       partitions: 2
       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.6.1
+          image: quay.io/numaio/numaflow-go/reduce-sum:stable
         groupBy:
           window:
             fixed:

diff --git a/test/reduce-two-e2e/testdata/reduce-stream/reduce-stream-go.yaml b/test/reduce-two-e2e/testdata/reduce-stream/reduce-stream-go.yaml
@@ -15,13 +15,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.6.1
+          image: quay.io/numaio/numaflow-go/map-even-odd:stable
     - name: compute-sum
       partitions: 2
       udf:
         container:
           # compute the sum, see https://github.com/numaproj/numaflow-go/tree/main/pkg/reducestreamer/examples/sum
-          image: quay.io/numaio/numaflow-go/reduce-stream-sum:v0.6.1
+          image: quay.io/numaio/numaflow-go/reduce-stream-sum:stable
         groupBy:
           window:
             fixed:

diff --git a/test/reduce-two-e2e/testdata/reduce-stream/reduce-stream-java.yaml b/test/reduce-two-e2e/testdata/reduce-stream/reduce-stream-java.yaml
@@ -15,13 +15,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.6.1
+          image: quay.io/numaio/numaflow-go/map-even-odd:stable
     - name: compute-sum
       partitions: 2
       udf:
         container:
           # compute the sum, see https://github.com/numaproj/numaflow-java/tree/main/examples/src/main/java/io/numaproj/numaflow/examples/reducestreamer/sum
-          image: quay.io/numaio/numaflow-java/reduce-stream-sum:v0.6.0
+          image: quay.io/numaio/numaflow-java/reduce-stream-sum:stable
         groupBy:
           window:
             fixed:

diff --git a/test/reduce-two-e2e/testdata/session-reduce/simple-session-keyed-counter-pipeline-go.yaml b/test/reduce-two-e2e/testdata/session-reduce/simple-session-keyed-counter-pipeline-go.yaml
@@ -16,13 +16,13 @@ spec:
         min: 1
       udf:
         container:
-          image: quay.io/numaio/numaflow-go/map-even-odd:v0.6.1
+          image: quay.io/numaio/numaflow-go/map-even-odd:stable
     - name: compute-count
       partitions: 1
       udf:
         container:
           # see https://github.com/numaproj/numaflow-go/tree/main/pkg/sessionreducer/examples/counter
-          image: quay.io/numaio/numaflow-go/session-counter:v0.6.1
+          image: quay.io/numaio/numaflow-go/session-counter:stable
         groupBy:
           window:
             session:

diff --git a/test/reduce-two-e2e/testdata/session-reduce/simple-session-keyed-counter-pipeline-java.yaml b/test/reduce-two-e2e/testdata/session-reduce/simple-session-keyed-counter-pipeline-java.yaml
@@ -16,7 +16,7 @@ spec:
         min: 1
       udf:
         container:
-          image: quay.io/numaio/numaflow-go/map-even-odd:v0.6.1
+          image: quay.io/numaio/numaflow-go/map-even-odd:stable
     - name: compute-count
       partitions: 1
       udf:

diff --git a/test/reduce-two-e2e/testdata/session-reduce/simple-session-sum-pipeline.yaml b/test/reduce-two-e2e/testdata/session-reduce/simple-session-sum-pipeline.yaml
@@ -15,7 +15,7 @@ spec:
       partitions: 1
       udf:
         container:
-          # see https://github.com/numaproj/numaflow-go/tree/main/pkg/sessionreducer/examples/counter
+          # TODO: Once the session-sum example is merged, add link to source code and change tag to stable
           image: quay.io/numaio/numaflow-go/session-sum:v0.6.1
           imagePullPolicy: Always
         groupBy:

diff --git a/test/sdks-e2e/testdata/flatmap-stream.yaml b/test/sdks-e2e/testdata/flatmap-stream.yaml
@@ -19,23 +19,23 @@ spec:
       udf:
         container:
           # Split input message into an array with comma, see https://github.com/numaproj/numaflow-go/tree/main/pkg/mapstreamer/examples/flatmap_stream
-          image: quay.io/numaio/numaflow-go/map-flatmap-stream:v0.6.1
+          image: quay.io/numaio/numaflow-go/map-flatmap-stream:stable
     - name: go-udsink
       scale:
         min: 1
       sink:
         udsink:
           container:
             # https://github.com/numaproj/numaflow-go/tree/main/pkg/sinker/examples/log
-            image: quay.io/numaio/numaflow-go/sink-log:v0.6.1
+            image: quay.io/numaio/numaflow-go/sink-log:stable
     - name: go-udsink-2
       scale:
         min: 1
       sink:
         udsink:
           container:
             # https://github.com/numaproj/numaflow-go/tree/main/pkg/sinker/examples/log
-            image: quay.io/numaio/numaflow-go/sink-log:v0.6.1
+            image: quay.io/numaio/numaflow-go/sink-log:stable
 
     - name: python-split
       partitions: 3
@@ -52,7 +52,7 @@ spec:
             - python
             - example.py
           # Split input message into an array with comma, https://github.com/numaproj/numaflow-python/tree/main/examples/mapstream/flatmap_stream
-          image: quay.io/numaio/numaflow-python/map-flatmap-stream:v0.6.0
+          image: quay.io/numaio/numaflow-python/map-flatmap-stream:stable
     - name: python-udsink
       scale:
         min: 1
@@ -63,7 +63,7 @@ spec:
               - python
               - example.py
             # https://github.com/numaproj/numaflow-python/tree/main/examples/sink/log
-            image: quay.io/numaio/numaflow-python/sink-log:v0.6.0
+            image: quay.io/numaio/numaflow-python/sink-log:stable
     - name: java-split
       partitions: 3
       metadata:
@@ -76,15 +76,15 @@ spec:
       udf:
         container:
           # Split input message into an array with comma, see https://github.com/numaproj/numaflow-java/tree/main/examples/src/main/java/io/numaproj/numaflow/examples/mapstream/flatmapstream
-          image: quay.io/numaio/numaflow-java/flat-map-stream:v0.6.0
+          image: quay.io/numaio/numaflow-java/flat-map-stream:stable
     - name: java-udsink
       scale:
         min: 1
       sink:
         udsink:
           container:
             # https://github.com/numaproj/numaflow-java/tree/main/examples/src/main/java/io/numaproj/numaflow/examples/sink/simple
-            image: quay.io/numaio/numaflow-java/simple-sink:v0.6.0
+            image: quay.io/numaio/numaflow-java/simple-sink:stable
   edges:
     - from: in
       to: go-split

diff --git a/test/sdks-e2e/testdata/flatmap.yaml b/test/sdks-e2e/testdata/flatmap.yaml
@@ -13,15 +13,15 @@ spec:
       udf:
         container:
           # Split input message into an array with comma, see https://github.com/numaproj/numaflow-go/tree/main/pkg/mapper/examples/flatmap
-          image: quay.io/numaio/numaflow-go/map-flatmap:v0.6.1
+          image: quay.io/numaio/numaflow-go/map-flatmap:stable
     - name: go-udsink
       scale:
         min: 1
       sink:
         udsink:
           container:
             # https://github.com/numaproj/numaflow-go/tree/main/pkg/sinker/examples/log
-            image: quay.io/numaio/numaflow-go/sink-log:v0.6.1
+            image: quay.io/numaio/numaflow-go/sink-log:stable
 
     - name: python-split
       scale:
@@ -32,7 +32,7 @@ spec:
             - python
             - example.py
           # Split input message into an array with comma, https://github.com/numaproj/numaflow-python/tree/main/examples/map/flatmap
-          image: quay.io/numaio/numaflow-python/map-flatmap:v0.6.0
+          image: quay.io/numaio/numaflow-python/map-flatmap:stable
     - name: python-udsink
       scale:
         min: 1
@@ -43,22 +43,22 @@ spec:
             - python
             - example.py
             # https://github.com/numaproj/numaflow-python/tree/main/examples/sink/log
-            image: quay.io/numaio/numaflow-python/sink-log:v0.6.0
+            image: quay.io/numaio/numaflow-python/sink-log:stable
     - name: java-split
       scale:
         min: 1
       udf:
         container:
           # Split input message into an array with comma, see https://github.com/numaproj/numaflow-java/tree/main/examples/src/main/java/io/numaproj/numaflow/examples/map/flatmap
-          image: quay.io/numaio/numaflow-java/map-flatmap:v0.6.0
+          image: quay.io/numaio/numaflow-java/map-flatmap:stable
     - name: java-udsink
       scale:
         min: 1
       sink:
         udsink:
           container:
             # https://github.com/numaproj/numaflow-java/tree/main/examples/src/main/java/io/numaproj/numaflow/examples/sink/simple
-            image: quay.io/numaio/numaflow-java/simple-sink:v0.6.0
+            image: quay.io/numaio/numaflow-java/simple-sink:stable
   edges:
     - from: in
       to: go-split

diff --git a/test/sdks-e2e/testdata/simple-keyed-reduce-pipeline.yaml b/test/sdks-e2e/testdata/simple-keyed-reduce-pipeline.yaml
@@ -13,13 +13,13 @@ spec:
       udf:
         container:
           # Tell the input number is even or odd, see https://github.com/numaproj/numaflow-java/tree/main/examples/src/main/java/io/numaproj/numaflow/examples/map/evenodd
-          image: quay.io/numaio/numaflow-java/even-odd:v0.6.0
+          image: quay.io/numaio/numaflow-java/even-odd:stable
     - name: compute-sum
       partitions: 2
       udf:
         container:
           # compute the sum, see https://github.com/numaproj/numaflow-java/tree/main/examples/src/main/java/io/numaproj/numaflow/examples/reduce/sum
-          image: quay.io/numaio/numaflow-java/reduce-sum:v0.6.0
+          image: quay.io/numaio/numaflow-java/reduce-sum:stable
         groupBy:
           window:
             fixed:
@@ -34,7 +34,7 @@ spec:
         udsink:
           container:
             # https://github.com/numaproj/numaflow-java/tree/main/examples/src/main/java/io/numaproj/numaflow/examples/sink/simple
-            image: quay.io/numaio/numaflow-java/simple-sink:v0.6.0
+            image: quay.io/numaio/numaflow-java/simple-sink:stable
   edges:
     - from: in
       to: atoi