Skip to content

Commit

Permalink
fix: update SDKs to stable image (#1746)
Browse files Browse the repository at this point in the history
Signed-off-by: Samhith Kakarla <samhith_kakarla@intuit.com>
  • Loading branch information
samhith-kakarla committed May 31, 2024
1 parent 30c42f6 commit 1e03eee
Show file tree
Hide file tree
Showing 12 changed files with 22 additions and 22 deletions.
2 changes: 1 addition & 1 deletion examples/10-cycle-to-prev.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -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
image: quay.io/numaio/numaflow-go/map-retry:stable
- name: out
scale:
min: 1
Expand Down
2 changes: 1 addition & 1 deletion examples/10-cycle-to-self.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -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
image: quay.io/numaio/numaflow-go/map-retry:stable
- name: out
scale:
min: 1
Expand Down
2 changes: 1 addition & 1 deletion examples/11-join-on-reduce.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -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
image: quay.io/numaio/numaflow-go/reduce-sum:stable
groupBy:
window:
fixed:
Expand Down
2 changes: 1 addition & 1 deletion examples/11-join-on-sink.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -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
image: quay.io/numaio/numaflow-go/map-even-odd:stable
- name: even-cat
udf:
builtin:
Expand Down
4 changes: 2 additions & 2 deletions examples/12-simple-session-pipeline.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -16,15 +16,15 @@ spec:
min: 1
udf:
container:
image: quay.io/numaio/numaflow-go/map-even-odd:v0.7.0-rc1
image: quay.io/numaio/numaflow-go/map-even-odd:stable
imagePullPolicy: Always
- name: compute-count
partitions: 1
udf:
container:
# see https://github.com/numaproj/numaflow-go/tree/main/pkg/sessionreducer/examples/counter
# computes the count of even numbers and odd numbers in a session
image: quay.io/numaio/numaflow-go/session-counter:v0.7.0-rc1
image: quay.io/numaio/numaflow-go/session-counter:stable
imagePullPolicy: Always
groupBy:
window:
Expand Down
4 changes: 2 additions & 2 deletions examples/13-streaming-reduce-pipeline.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -15,15 +15,15 @@ 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:stable
imagePullPolicy: Always
- name: compute-sum
partitions: 2
udf:
container:
# compute the sum, see https://github.com/numaproj/numaflow-go/tree/main/pkg/reducestreamer/examples/sum
# Writes output to next vertex if the sum is greater than 100, does not wait for the window to close.
image: quay.io/numaio/numaflow-go/reduce-stream-sum:v0.7.0-rc1
image: quay.io/numaio/numaflow-go/reduce-stream-sum:stable
imagePullPolicy: Always
groupBy:
window:
Expand Down
4 changes: 2 additions & 2 deletions examples/14-simple-fallback-pipeline.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -22,12 +22,12 @@ spec:
sink:
udsink:
container:
image: quay.io/numaio/numaflow-go/fb-sink-log:v0.7.0
image: quay.io/numaio/numaflow-go/fb-sink-log:stable
imagePullPolicy: Always
fallback:
udsink:
container:
image: quay.io/numaio/numaflow-go/fb-sink-log:v0.7.0
image: quay.io/numaio/numaflow-go/fb-sink-log:stable
edges:
- from: in
to: cat
Expand Down
2 changes: 1 addition & 1 deletion examples/2-even-odd-pipeline.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -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
image: quay.io/numaio/numaflow-go/map-even-odd:stable
- name: even-sink
scale:
min: 1
Expand Down
4 changes: 2 additions & 2 deletions examples/6-reduce-fixed-window-with-pvc.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -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
image: quay.io/numaio/numaflow-go/map-even-odd:stable
- name: compute-sum
udf:
container:
# compute the sum
image: quay.io/numaio/numaflow-go/reduce-sum:v0.7.0
image: quay.io/numaio/numaflow-go/reduce-sum:stable
groupBy:
window:
fixed:
Expand Down
4 changes: 2 additions & 2 deletions examples/6-reduce-fixed-window.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -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
image: quay.io/numaio/numaflow-go/map-even-odd:stable
- name: compute-sum
udf:
container:
# compute the sum
image: quay.io/numaio/numaflow-go/reduce-sum:v0.7.0
image: quay.io/numaio/numaflow-go/reduce-sum:stable
groupBy:
window:
fixed:
Expand Down
6 changes: 3 additions & 3 deletions examples/7-reduce-sliding-window.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -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
image: quay.io/numaio/numaflow-go/map-even-odd:stable
- name: reduce-sliding
partitions: 2
udf:
container:
# compute the sum
image: quay.io/numaio/numaflow-go/reduce-sum:v0.7.0
image: quay.io/numaio/numaflow-go/reduce-sum:stable
groupBy:
window:
sliding:
Expand All @@ -57,4 +57,4 @@ spec:
- from: map
to: reduce-sliding
- from: reduce-sliding
to: sink
to: sink
8 changes: 4 additions & 4 deletions examples/8-reduce-complex-pipeline.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -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
image: quay.io/numaio/numaflow-go/map-even-odd:stable
- name: keyed-fixed-sum
partitions: 2
udf:
container:
# compute the sum
image: quay.io/numaio/numaflow-go/reduce-sum:v0.7.0
image: quay.io/numaio/numaflow-go/reduce-sum:stable
groupBy:
window:
fixed:
Expand All @@ -37,7 +37,7 @@ spec:
udf:
container:
# compute the sum
image: quay.io/numaio/numaflow-go/reduce-sum:v0.7.0
image: quay.io/numaio/numaflow-go/reduce-sum:stable
groupBy:
window:
fixed:
Expand All @@ -51,7 +51,7 @@ spec:
udf:
container:
# compute the sum
image: quay.io/numaio/numaflow-go/reduce-sum:v0.7.0
image: quay.io/numaio/numaflow-go/reduce-sum:stable
groupBy:
window:
sliding:
Expand Down

0 comments on commit 1e03eee

Please sign in to comment.