From 38f9d7d677ebb7231c246e9e46b1f8cddf0c71fb Mon Sep 17 00:00:00 2001 From: a3hadi Date: Wed, 28 Feb 2024 23:12:55 -0500 Subject: [PATCH 01/15] POC for improved ci/cd Signed-off-by: a3hadi --- .github/workflows/buid-push.yaml | 41 +++++++++++++++++++ .../workflows/update-sdk-dependencies.yaml | 36 ++++++++++++++++ traverse-examples.sh | 14 +++++++ 3 files changed, 91 insertions(+) create mode 100644 .github/workflows/buid-push.yaml create mode 100644 .github/workflows/update-sdk-dependencies.yaml create mode 100755 traverse-examples.sh diff --git a/.github/workflows/buid-push.yaml b/.github/workflows/buid-push.yaml new file mode 100644 index 00000000..5c732140 --- /dev/null +++ b/.github/workflows/buid-push.yaml @@ -0,0 +1,41 @@ +on: + pull_request: + types: + - closed + paths: + - "pkg/*/examples/*" + +jobs: + if_merged: + if: github.event.pull_request.merged == true + name: Build and Push Images + runs-on: ubuntu-latest + + strategy: + matrix: + repository: [ + "map-even-odd", "map-flatmap", "map-forward-message", "map-retry", "map-tickgen" + ] + + steps: + - name: Set up QEMU + uses: docker/setup-qemu-action@v3 + - name: Set up Docker Buildx + uses: docker/setup-buildx-action@v3 + - name: Login to Quay.io registry + env: + QUAY_USERNAME: ${{ secrets.QUAY_USERNAME }} + QUAY_PASSWORD: ${{ secrets.QUAY_PASSWORD }} + uses: docker/login-action@v3 + with: + registry: quay.io + username: ${{ env.QUAY_USERNAME }} + password: ${{ env.QUAY_PASSWORD }} + - name: Build and tag images + run: ./traverse-examples "make image" + - name: Push images + env: + IMAGE_PREFIX: "quay.io/numaio/numaflow-go" + TAG: "stable" + run: | + docker push ${{ env.IMAGE_PREFIX }}/${{ matrix.repository }}:${{ env.TAG }} diff --git a/.github/workflows/update-sdk-dependencies.yaml b/.github/workflows/update-sdk-dependencies.yaml new file mode 100644 index 00000000..312d09d1 --- /dev/null +++ b/.github/workflows/update-sdk-dependencies.yaml @@ -0,0 +1,36 @@ +on: + pull_request: + types: + - closed + paths-ignore: + - 'pkg/*/examples/*' + - '*.md' + +jobs: + if_merged: + if: github.event.pull_request.merged == true + name: Update Go SDK Version + runs-on: ubuntu-latest + env: + COMMIT_SHA: ${{ github.sha }} # refers to the SHA of the merge commit, not the individual commits in PR + + steps: + - name: Setup Go + uses: actions/setup-go@v4.0.0 + with: + go-version: '1.20' + - name: Checkout code + uses: actions/checkout@v3 # includes the changes from merged PR + - name: Update dependencies + run: ./traverse-examples.sh "go get github.com/numaproj/numaflow-go@${{ env.COMMIT_SHA }}" "go mod tidy" + + - name: Create PR + uses: peter-evans/create-pull-request@v6 + with: + branch: update-sdk-${{ env.COMMIT_SHA }} + title: "chore: update sdk version" + body: "Modify go.mod and go.sum in the example folders, so that they use an up to date version of the GO SDK" + commit-message: "Update dependency files to point to latest version of numaflow-go" + base: main + signoff: true + diff --git a/traverse-examples.sh b/traverse-examples.sh new file mode 100755 index 00000000..b455fae3 --- /dev/null +++ b/traverse-examples.sh @@ -0,0 +1,14 @@ +#!/bin/bash + +commands=( "$@" ) + +find pkg -name "go.mod" | while read -r line; +do + dir="$(dirname "${line}")" + cd "$dir" || exit + for cmd in "${commands[@]}" + do + eval "$cmd" + done + cd ~- || exit +done From 5fbc86fb86d2c93ab267011135fb4f1558682c72 Mon Sep 17 00:00:00 2001 From: a3hadi Date: Wed, 28 Feb 2024 23:13:16 -0500 Subject: [PATCH 02/15] remove white space Signed-off-by: a3hadi --- .github/workflows/update-sdk-dependencies.yaml | 1 - 1 file changed, 1 deletion(-) diff --git a/.github/workflows/update-sdk-dependencies.yaml b/.github/workflows/update-sdk-dependencies.yaml index 312d09d1..f6e030e9 100644 --- a/.github/workflows/update-sdk-dependencies.yaml +++ b/.github/workflows/update-sdk-dependencies.yaml @@ -33,4 +33,3 @@ jobs: commit-message: "Update dependency files to point to latest version of numaflow-go" base: main signoff: true - From a02b0fc40c01057771408a36438aa812d8665833 Mon Sep 17 00:00:00 2001 From: a3hadi Date: Wed, 28 Feb 2024 23:27:43 -0500 Subject: [PATCH 03/15] refactor Signed-off-by: a3hadi --- .../scripts/traverse-examples.sh | 0 .github/workflows/buid-push.yaml | 5 +++-- .github/workflows/update-sdk-dependencies.yaml | 6 +++--- 3 files changed, 6 insertions(+), 5 deletions(-) rename traverse-examples.sh => .github/scripts/traverse-examples.sh (100%) diff --git a/traverse-examples.sh b/.github/scripts/traverse-examples.sh similarity index 100% rename from traverse-examples.sh rename to .github/scripts/traverse-examples.sh diff --git a/.github/workflows/buid-push.yaml b/.github/workflows/buid-push.yaml index 5c732140..6eab899e 100644 --- a/.github/workflows/buid-push.yaml +++ b/.github/workflows/buid-push.yaml @@ -14,7 +14,8 @@ jobs: strategy: matrix: repository: [ - "map-even-odd", "map-flatmap", "map-forward-message", "map-retry", "map-tickgen" + "map-even-odd", "map-flatmap", "map-forward-message", "map-retry", "map-tickgen", + "map-flatmap-stream" ] steps: @@ -32,7 +33,7 @@ jobs: username: ${{ env.QUAY_USERNAME }} password: ${{ env.QUAY_PASSWORD }} - name: Build and tag images - run: ./traverse-examples "make image" + run: ./.github/scripts/traverse-examples.sh "make image" - name: Push images env: IMAGE_PREFIX: "quay.io/numaio/numaflow-go" diff --git a/.github/workflows/update-sdk-dependencies.yaml b/.github/workflows/update-sdk-dependencies.yaml index f6e030e9..520bccce 100644 --- a/.github/workflows/update-sdk-dependencies.yaml +++ b/.github/workflows/update-sdk-dependencies.yaml @@ -3,8 +3,8 @@ on: types: - closed paths-ignore: - - 'pkg/*/examples/*' - - '*.md' + - "pkg/*/examples/*" + - "*.md" jobs: if_merged: @@ -22,7 +22,7 @@ jobs: - name: Checkout code uses: actions/checkout@v3 # includes the changes from merged PR - name: Update dependencies - run: ./traverse-examples.sh "go get github.com/numaproj/numaflow-go@${{ env.COMMIT_SHA }}" "go mod tidy" + run: ./.github/scripts/traverse-examples.sh "go get github.com/numaproj/numaflow-go@${{ env.COMMIT_SHA }}" "go mod tidy" - name: Create PR uses: peter-evans/create-pull-request@v6 From c3146b546cb374fc42e306c41c837b9c35c35d10 Mon Sep 17 00:00:00 2001 From: a3hadi Date: Mon, 4 Mar 2024 10:56:26 -0500 Subject: [PATCH 04/15] modify workflows Signed-off-by: a3hadi --- .github/workflows/buid-push.yaml | 7 +++++-- .github/workflows/update-sdk-dependencies.yaml | 7 ++++--- 2 files changed, 9 insertions(+), 5 deletions(-) diff --git a/.github/workflows/buid-push.yaml b/.github/workflows/buid-push.yaml index 6eab899e..e697f7e0 100644 --- a/.github/workflows/buid-push.yaml +++ b/.github/workflows/buid-push.yaml @@ -3,7 +3,8 @@ on: types: - closed paths: - - "pkg/*/examples/*" + - "pkg/*/examples/go.sum" + - "pkg/*/examples/go.mod" jobs: if_merged: @@ -15,7 +16,9 @@ jobs: matrix: repository: [ "map-even-odd", "map-flatmap", "map-forward-message", "map-retry", "map-tickgen", - "map-flatmap-stream" + "map-flatmap-stream", "reduce-counter", "reduce-sum", "reduce-stream-counter", + "reduce-stream-sum", "session-counter", "sideinput-example", "udf-sideinput-example", + "sink-log", "source-simple-source", "mapt-assign-event-time", "mapt-event-time-filter" ] steps: diff --git a/.github/workflows/update-sdk-dependencies.yaml b/.github/workflows/update-sdk-dependencies.yaml index 520bccce..8906a5cc 100644 --- a/.github/workflows/update-sdk-dependencies.yaml +++ b/.github/workflows/update-sdk-dependencies.yaml @@ -3,7 +3,8 @@ on: types: - closed paths-ignore: - - "pkg/*/examples/*" + - "pkg/*/examples/go.sum" + - "pkg/*/examples/go.mod" - "*.md" jobs: @@ -18,7 +19,7 @@ jobs: - name: Setup Go uses: actions/setup-go@v4.0.0 with: - go-version: '1.20' + go-version: "1.20" - name: Checkout code uses: actions/checkout@v3 # includes the changes from merged PR - name: Update dependencies @@ -30,6 +31,6 @@ jobs: branch: update-sdk-${{ env.COMMIT_SHA }} title: "chore: update sdk version" body: "Modify go.mod and go.sum in the example folders, so that they use an up to date version of the GO SDK" - commit-message: "Update dependency files to point to latest version of numaflow-go" + commit-message: "Update dependency files to point to latest commit of numaflow-go" base: main signoff: true From 7e4fa1fcdc94e5bbdc731ce94dbe8aa4882ff350 Mon Sep 17 00:00:00 2001 From: a3hadi Date: Tue, 5 Mar 2024 11:33:37 -0500 Subject: [PATCH 05/15] modify go.mod to use local references Signed-off-by: a3hadi --- pkg/mapper/examples/even_odd/go.mod | 4 +++- pkg/mapper/examples/even_odd/go.sum | 2 -- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/pkg/mapper/examples/even_odd/go.mod b/pkg/mapper/examples/even_odd/go.mod index c221cdcb..02646270 100644 --- a/pkg/mapper/examples/even_odd/go.mod +++ b/pkg/mapper/examples/even_odd/go.mod @@ -2,7 +2,7 @@ module even_odd go 1.20 -require github.com/numaproj/numaflow-go v0.6.1-0.20240212202512-715955f1e069 +require github.com/numaproj/numaflow-go v0.6.0 require ( github.com/golang/protobuf v1.5.3 // indirect @@ -13,3 +13,5 @@ require ( google.golang.org/grpc v1.57.0 // indirect google.golang.org/protobuf v1.31.0 // indirect ) + +replace github.com/numaproj/numaflow-go => ../../../../../numaflow-go diff --git a/pkg/mapper/examples/even_odd/go.sum b/pkg/mapper/examples/even_odd/go.sum index dd3945cb..95c8479a 100644 --- a/pkg/mapper/examples/even_odd/go.sum +++ b/pkg/mapper/examples/even_odd/go.sum @@ -4,8 +4,6 @@ github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= -github.com/numaproj/numaflow-go v0.6.1-0.20240212202512-715955f1e069 h1:LBMIrUytoxuZazEnwxo+WPAxjHL1rrVhphTyByLiDYY= -github.com/numaproj/numaflow-go v0.6.1-0.20240212202512-715955f1e069/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk= golang.org/x/net v0.9.0 h1:aWJ/m6xSmxWBx+V0XRHTlrYrPG56jKsLdTFmsSsCzOM= From 9b670de806a7d11fcb7c12337ddd901a5b68d038 Mon Sep 17 00:00:00 2001 From: a3hadi Date: Tue, 5 Mar 2024 16:36:53 -0500 Subject: [PATCH 06/15] script to automate dependency update Signed-off-by: a3hadi --- pkg/mapper/examples/even_odd/go.mod | 6 +++--- pkg/mapper/examples/flatmap/go.mod | 2 +- pkg/mapper/examples/flatmap/go.sum | 4 ++-- pkg/mapper/examples/forward_message/go.mod | 2 +- pkg/mapper/examples/forward_message/go.sum | 4 ++-- pkg/mapper/examples/retry/go.mod | 2 +- pkg/mapper/examples/retry/go.sum | 4 ++-- pkg/mapper/examples/tickgen/go.mod | 2 +- pkg/mapper/examples/tickgen/go.sum | 4 ++-- .../examples/flatmap_stream/go.mod | 2 +- .../examples/flatmap_stream/go.sum | 4 ++-- pkg/reducer/examples/counter/go.mod | 2 +- pkg/reducer/examples/counter/go.sum | 4 ++-- pkg/reducer/examples/sum/go.mod | 2 +- pkg/reducer/examples/sum/go.sum | 4 ++-- pkg/reducestreamer/examples/counter/go.mod | 2 +- pkg/reducestreamer/examples/counter/go.sum | 6 ++---- pkg/reducestreamer/examples/sum/go.mod | 2 +- pkg/reducestreamer/examples/sum/go.sum | 4 ++-- pkg/sessionreducer/examples/counter/go.mod | 2 +- pkg/sessionreducer/examples/counter/go.sum | 4 ++-- .../examples/simple-sideinput/go.mod | 2 +- .../examples/simple-sideinput/go.sum | 4 ++-- .../examples/simple-sideinput/udf/go.mod | 2 +- .../examples/simple-sideinput/udf/go.sum | 4 ++-- pkg/sinker/examples/log/go.mod | 2 +- pkg/sinker/examples/log/go.sum | 4 ++-- pkg/sourcer/examples/simple_source/go.mod | 2 +- pkg/sourcer/examples/simple_source/go.sum | 4 ++-- .../examples/assign_event_time/go.mod | 2 +- .../examples/assign_event_time/go.sum | 4 ++-- .../examples/event_time_filter/go.mod | 2 +- .../examples/event_time_filter/go.sum | 4 ++-- update-sdk-version.sh | 21 +++++++++++++++++++ 34 files changed, 72 insertions(+), 53 deletions(-) create mode 100755 update-sdk-version.sh diff --git a/pkg/mapper/examples/even_odd/go.mod b/pkg/mapper/examples/even_odd/go.mod index 02646270..139fd86f 100644 --- a/pkg/mapper/examples/even_odd/go.mod +++ b/pkg/mapper/examples/even_odd/go.mod @@ -2,7 +2,9 @@ module even_odd go 1.20 -require github.com/numaproj/numaflow-go v0.6.0 +replace github.com/numaproj/numaflow-go => ../../../../../numaflow-go + +require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 require ( github.com/golang/protobuf v1.5.3 // indirect @@ -13,5 +15,3 @@ require ( google.golang.org/grpc v1.57.0 // indirect google.golang.org/protobuf v1.31.0 // indirect ) - -replace github.com/numaproj/numaflow-go => ../../../../../numaflow-go diff --git a/pkg/mapper/examples/flatmap/go.mod b/pkg/mapper/examples/flatmap/go.mod index d8716054..12d2c1a8 100644 --- a/pkg/mapper/examples/flatmap/go.mod +++ b/pkg/mapper/examples/flatmap/go.mod @@ -2,7 +2,7 @@ module flatmap go 1.20 -require github.com/numaproj/numaflow-go v0.6.1-0.20240212202512-715955f1e069 +require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 require ( github.com/golang/protobuf v1.5.3 // indirect diff --git a/pkg/mapper/examples/flatmap/go.sum b/pkg/mapper/examples/flatmap/go.sum index dd3945cb..77fd11a5 100644 --- a/pkg/mapper/examples/flatmap/go.sum +++ b/pkg/mapper/examples/flatmap/go.sum @@ -4,8 +4,8 @@ github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= -github.com/numaproj/numaflow-go v0.6.1-0.20240212202512-715955f1e069 h1:LBMIrUytoxuZazEnwxo+WPAxjHL1rrVhphTyByLiDYY= -github.com/numaproj/numaflow-go v0.6.1-0.20240212202512-715955f1e069/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= +github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 h1:yY1ZjhfqdxE9H4T9YRff+GJHilv9CJgslWEYfsE/EPo= +github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk= golang.org/x/net v0.9.0 h1:aWJ/m6xSmxWBx+V0XRHTlrYrPG56jKsLdTFmsSsCzOM= diff --git a/pkg/mapper/examples/forward_message/go.mod b/pkg/mapper/examples/forward_message/go.mod index 4380978e..ea43aab5 100644 --- a/pkg/mapper/examples/forward_message/go.mod +++ b/pkg/mapper/examples/forward_message/go.mod @@ -2,7 +2,7 @@ module even_odd go 1.20 -require github.com/numaproj/numaflow-go v0.6.0 +require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 require ( github.com/golang/protobuf v1.5.3 // indirect diff --git a/pkg/mapper/examples/forward_message/go.sum b/pkg/mapper/examples/forward_message/go.sum index 8b1ed758..77fd11a5 100644 --- a/pkg/mapper/examples/forward_message/go.sum +++ b/pkg/mapper/examples/forward_message/go.sum @@ -4,8 +4,8 @@ github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= -github.com/numaproj/numaflow-go v0.6.0 h1:gqTX1u1pFJJhX/3l3zYM8aLqRSHEainYrgBIollL0js= -github.com/numaproj/numaflow-go v0.6.0/go.mod h1:5zwvvREIbqaCPCKsNE1MVjVToD0kvkCh2Z90Izlhw5U= +github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 h1:yY1ZjhfqdxE9H4T9YRff+GJHilv9CJgslWEYfsE/EPo= +github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk= golang.org/x/net v0.9.0 h1:aWJ/m6xSmxWBx+V0XRHTlrYrPG56jKsLdTFmsSsCzOM= diff --git a/pkg/mapper/examples/retry/go.mod b/pkg/mapper/examples/retry/go.mod index 2be14290..4baf8336 100644 --- a/pkg/mapper/examples/retry/go.mod +++ b/pkg/mapper/examples/retry/go.mod @@ -2,7 +2,7 @@ module retry go 1.20 -require github.com/numaproj/numaflow-go v0.6.1-0.20240212202512-715955f1e069 +require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 require ( github.com/golang/protobuf v1.5.3 // indirect diff --git a/pkg/mapper/examples/retry/go.sum b/pkg/mapper/examples/retry/go.sum index dd3945cb..77fd11a5 100644 --- a/pkg/mapper/examples/retry/go.sum +++ b/pkg/mapper/examples/retry/go.sum @@ -4,8 +4,8 @@ github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= -github.com/numaproj/numaflow-go v0.6.1-0.20240212202512-715955f1e069 h1:LBMIrUytoxuZazEnwxo+WPAxjHL1rrVhphTyByLiDYY= -github.com/numaproj/numaflow-go v0.6.1-0.20240212202512-715955f1e069/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= +github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 h1:yY1ZjhfqdxE9H4T9YRff+GJHilv9CJgslWEYfsE/EPo= +github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk= golang.org/x/net v0.9.0 h1:aWJ/m6xSmxWBx+V0XRHTlrYrPG56jKsLdTFmsSsCzOM= diff --git a/pkg/mapper/examples/tickgen/go.mod b/pkg/mapper/examples/tickgen/go.mod index c9208575..44e3029f 100644 --- a/pkg/mapper/examples/tickgen/go.mod +++ b/pkg/mapper/examples/tickgen/go.mod @@ -2,7 +2,7 @@ module tickgen go 1.20 -require github.com/numaproj/numaflow-go v0.6.0 +require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 require ( github.com/golang/protobuf v1.5.3 // indirect diff --git a/pkg/mapper/examples/tickgen/go.sum b/pkg/mapper/examples/tickgen/go.sum index 8b1ed758..77fd11a5 100644 --- a/pkg/mapper/examples/tickgen/go.sum +++ b/pkg/mapper/examples/tickgen/go.sum @@ -4,8 +4,8 @@ github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= -github.com/numaproj/numaflow-go v0.6.0 h1:gqTX1u1pFJJhX/3l3zYM8aLqRSHEainYrgBIollL0js= -github.com/numaproj/numaflow-go v0.6.0/go.mod h1:5zwvvREIbqaCPCKsNE1MVjVToD0kvkCh2Z90Izlhw5U= +github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 h1:yY1ZjhfqdxE9H4T9YRff+GJHilv9CJgslWEYfsE/EPo= +github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk= golang.org/x/net v0.9.0 h1:aWJ/m6xSmxWBx+V0XRHTlrYrPG56jKsLdTFmsSsCzOM= diff --git a/pkg/mapstreamer/examples/flatmap_stream/go.mod b/pkg/mapstreamer/examples/flatmap_stream/go.mod index 674fd116..bd46bc21 100644 --- a/pkg/mapstreamer/examples/flatmap_stream/go.mod +++ b/pkg/mapstreamer/examples/flatmap_stream/go.mod @@ -2,7 +2,7 @@ module flatmap_stream go 1.20 -require github.com/numaproj/numaflow-go v0.6.1-0.20240212202512-715955f1e069 +require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 require ( github.com/golang/protobuf v1.5.3 // indirect diff --git a/pkg/mapstreamer/examples/flatmap_stream/go.sum b/pkg/mapstreamer/examples/flatmap_stream/go.sum index dd3945cb..77fd11a5 100644 --- a/pkg/mapstreamer/examples/flatmap_stream/go.sum +++ b/pkg/mapstreamer/examples/flatmap_stream/go.sum @@ -4,8 +4,8 @@ github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= -github.com/numaproj/numaflow-go v0.6.1-0.20240212202512-715955f1e069 h1:LBMIrUytoxuZazEnwxo+WPAxjHL1rrVhphTyByLiDYY= -github.com/numaproj/numaflow-go v0.6.1-0.20240212202512-715955f1e069/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= +github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 h1:yY1ZjhfqdxE9H4T9YRff+GJHilv9CJgslWEYfsE/EPo= +github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk= golang.org/x/net v0.9.0 h1:aWJ/m6xSmxWBx+V0XRHTlrYrPG56jKsLdTFmsSsCzOM= diff --git a/pkg/reducer/examples/counter/go.mod b/pkg/reducer/examples/counter/go.mod index a9a885a9..96927fbd 100644 --- a/pkg/reducer/examples/counter/go.mod +++ b/pkg/reducer/examples/counter/go.mod @@ -2,7 +2,7 @@ module counter go 1.20 -require github.com/numaproj/numaflow-go v0.6.1-0.20240212202512-715955f1e069 +require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 require ( github.com/golang/protobuf v1.5.3 // indirect diff --git a/pkg/reducer/examples/counter/go.sum b/pkg/reducer/examples/counter/go.sum index d8cad981..727ad275 100644 --- a/pkg/reducer/examples/counter/go.sum +++ b/pkg/reducer/examples/counter/go.sum @@ -4,8 +4,8 @@ github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= -github.com/numaproj/numaflow-go v0.6.1-0.20240212202512-715955f1e069 h1:LBMIrUytoxuZazEnwxo+WPAxjHL1rrVhphTyByLiDYY= -github.com/numaproj/numaflow-go v0.6.1-0.20240212202512-715955f1e069/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= +github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 h1:yY1ZjhfqdxE9H4T9YRff+GJHilv9CJgslWEYfsE/EPo= +github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk= golang.org/x/net v0.9.0 h1:aWJ/m6xSmxWBx+V0XRHTlrYrPG56jKsLdTFmsSsCzOM= diff --git a/pkg/reducer/examples/sum/go.mod b/pkg/reducer/examples/sum/go.mod index 7dc7c35c..e8aff403 100644 --- a/pkg/reducer/examples/sum/go.mod +++ b/pkg/reducer/examples/sum/go.mod @@ -2,7 +2,7 @@ module sum go 1.20 -require github.com/numaproj/numaflow-go v0.6.1-0.20240212202512-715955f1e069 +require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 require ( github.com/golang/protobuf v1.5.3 // indirect diff --git a/pkg/reducer/examples/sum/go.sum b/pkg/reducer/examples/sum/go.sum index d8cad981..727ad275 100644 --- a/pkg/reducer/examples/sum/go.sum +++ b/pkg/reducer/examples/sum/go.sum @@ -4,8 +4,8 @@ github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= -github.com/numaproj/numaflow-go v0.6.1-0.20240212202512-715955f1e069 h1:LBMIrUytoxuZazEnwxo+WPAxjHL1rrVhphTyByLiDYY= -github.com/numaproj/numaflow-go v0.6.1-0.20240212202512-715955f1e069/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= +github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 h1:yY1ZjhfqdxE9H4T9YRff+GJHilv9CJgslWEYfsE/EPo= +github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk= golang.org/x/net v0.9.0 h1:aWJ/m6xSmxWBx+V0XRHTlrYrPG56jKsLdTFmsSsCzOM= diff --git a/pkg/reducestreamer/examples/counter/go.mod b/pkg/reducestreamer/examples/counter/go.mod index 21d79eb1..96927fbd 100644 --- a/pkg/reducestreamer/examples/counter/go.mod +++ b/pkg/reducestreamer/examples/counter/go.mod @@ -2,7 +2,7 @@ module counter go 1.20 -require github.com/numaproj/numaflow-go v0.6.1-0.20231219080635-d096c415a42f +require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 require ( github.com/golang/protobuf v1.5.3 // indirect diff --git a/pkg/reducestreamer/examples/counter/go.sum b/pkg/reducestreamer/examples/counter/go.sum index 32cb64f7..727ad275 100644 --- a/pkg/reducestreamer/examples/counter/go.sum +++ b/pkg/reducestreamer/examples/counter/go.sum @@ -4,10 +4,8 @@ github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= -github.com/numaproj/numaflow-go v0.5.3-0.20231211071430-1231c4c278e0 h1:aX6z3AIiJzA0XySqAZhP5ytZDZ3jcsQQnL81HP5mipU= -github.com/numaproj/numaflow-go v0.5.3-0.20231211071430-1231c4c278e0/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= -github.com/numaproj/numaflow-go v0.6.1-0.20231219080635-d096c415a42f h1:J43ekeRVzE6WGgkWl5oEQ+c4NT1i4VikMkygu4AeUYE= -github.com/numaproj/numaflow-go v0.6.1-0.20231219080635-d096c415a42f/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= +github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 h1:yY1ZjhfqdxE9H4T9YRff+GJHilv9CJgslWEYfsE/EPo= +github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk= golang.org/x/net v0.9.0 h1:aWJ/m6xSmxWBx+V0XRHTlrYrPG56jKsLdTFmsSsCzOM= diff --git a/pkg/reducestreamer/examples/sum/go.mod b/pkg/reducestreamer/examples/sum/go.mod index 7dc7c35c..e8aff403 100644 --- a/pkg/reducestreamer/examples/sum/go.mod +++ b/pkg/reducestreamer/examples/sum/go.mod @@ -2,7 +2,7 @@ module sum go 1.20 -require github.com/numaproj/numaflow-go v0.6.1-0.20240212202512-715955f1e069 +require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 require ( github.com/golang/protobuf v1.5.3 // indirect diff --git a/pkg/reducestreamer/examples/sum/go.sum b/pkg/reducestreamer/examples/sum/go.sum index d8cad981..727ad275 100644 --- a/pkg/reducestreamer/examples/sum/go.sum +++ b/pkg/reducestreamer/examples/sum/go.sum @@ -4,8 +4,8 @@ github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= -github.com/numaproj/numaflow-go v0.6.1-0.20240212202512-715955f1e069 h1:LBMIrUytoxuZazEnwxo+WPAxjHL1rrVhphTyByLiDYY= -github.com/numaproj/numaflow-go v0.6.1-0.20240212202512-715955f1e069/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= +github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 h1:yY1ZjhfqdxE9H4T9YRff+GJHilv9CJgslWEYfsE/EPo= +github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk= golang.org/x/net v0.9.0 h1:aWJ/m6xSmxWBx+V0XRHTlrYrPG56jKsLdTFmsSsCzOM= diff --git a/pkg/sessionreducer/examples/counter/go.mod b/pkg/sessionreducer/examples/counter/go.mod index 52677083..c416c1cf 100644 --- a/pkg/sessionreducer/examples/counter/go.mod +++ b/pkg/sessionreducer/examples/counter/go.mod @@ -3,7 +3,7 @@ module counter go 1.20 require ( - github.com/numaproj/numaflow-go v0.6.1-0.20240212202512-715955f1e069 + github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 go.uber.org/atomic v1.11.0 ) diff --git a/pkg/sessionreducer/examples/counter/go.sum b/pkg/sessionreducer/examples/counter/go.sum index 59ce47da..393c6c5c 100644 --- a/pkg/sessionreducer/examples/counter/go.sum +++ b/pkg/sessionreducer/examples/counter/go.sum @@ -4,8 +4,8 @@ github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= -github.com/numaproj/numaflow-go v0.6.1-0.20240212202512-715955f1e069 h1:LBMIrUytoxuZazEnwxo+WPAxjHL1rrVhphTyByLiDYY= -github.com/numaproj/numaflow-go v0.6.1-0.20240212202512-715955f1e069/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= +github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 h1:yY1ZjhfqdxE9H4T9YRff+GJHilv9CJgslWEYfsE/EPo= +github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk= go.uber.org/atomic v1.11.0 h1:ZvwS0R+56ePWxUNi+Atn9dWONBPp/AUETXlHW0DxSjE= diff --git a/pkg/sideinput/examples/simple-sideinput/go.mod b/pkg/sideinput/examples/simple-sideinput/go.mod index 64056201..541837d4 100644 --- a/pkg/sideinput/examples/simple-sideinput/go.mod +++ b/pkg/sideinput/examples/simple-sideinput/go.mod @@ -2,7 +2,7 @@ module sideinput go 1.20 -require github.com/numaproj/numaflow-go v0.6.0 +require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 require ( github.com/golang/protobuf v1.5.3 // indirect diff --git a/pkg/sideinput/examples/simple-sideinput/go.sum b/pkg/sideinput/examples/simple-sideinput/go.sum index 8b1ed758..77fd11a5 100644 --- a/pkg/sideinput/examples/simple-sideinput/go.sum +++ b/pkg/sideinput/examples/simple-sideinput/go.sum @@ -4,8 +4,8 @@ github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= -github.com/numaproj/numaflow-go v0.6.0 h1:gqTX1u1pFJJhX/3l3zYM8aLqRSHEainYrgBIollL0js= -github.com/numaproj/numaflow-go v0.6.0/go.mod h1:5zwvvREIbqaCPCKsNE1MVjVToD0kvkCh2Z90Izlhw5U= +github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 h1:yY1ZjhfqdxE9H4T9YRff+GJHilv9CJgslWEYfsE/EPo= +github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk= golang.org/x/net v0.9.0 h1:aWJ/m6xSmxWBx+V0XRHTlrYrPG56jKsLdTFmsSsCzOM= diff --git a/pkg/sideinput/examples/simple-sideinput/udf/go.mod b/pkg/sideinput/examples/simple-sideinput/udf/go.mod index 261a985d..ef03b57a 100644 --- a/pkg/sideinput/examples/simple-sideinput/udf/go.mod +++ b/pkg/sideinput/examples/simple-sideinput/udf/go.mod @@ -4,7 +4,7 @@ go 1.20 require ( github.com/fsnotify/fsnotify v1.6.0 - github.com/numaproj/numaflow-go v0.6.0 + github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 ) require ( diff --git a/pkg/sideinput/examples/simple-sideinput/udf/go.sum b/pkg/sideinput/examples/simple-sideinput/udf/go.sum index 66525120..e747e57f 100644 --- a/pkg/sideinput/examples/simple-sideinput/udf/go.sum +++ b/pkg/sideinput/examples/simple-sideinput/udf/go.sum @@ -6,8 +6,8 @@ github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= -github.com/numaproj/numaflow-go v0.6.0 h1:gqTX1u1pFJJhX/3l3zYM8aLqRSHEainYrgBIollL0js= -github.com/numaproj/numaflow-go v0.6.0/go.mod h1:5zwvvREIbqaCPCKsNE1MVjVToD0kvkCh2Z90Izlhw5U= +github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 h1:yY1ZjhfqdxE9H4T9YRff+GJHilv9CJgslWEYfsE/EPo= +github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk= golang.org/x/net v0.9.0 h1:aWJ/m6xSmxWBx+V0XRHTlrYrPG56jKsLdTFmsSsCzOM= diff --git a/pkg/sinker/examples/log/go.mod b/pkg/sinker/examples/log/go.mod index 47d1938b..938fe1f2 100644 --- a/pkg/sinker/examples/log/go.mod +++ b/pkg/sinker/examples/log/go.mod @@ -2,7 +2,7 @@ module log_sink go 1.20 -require github.com/numaproj/numaflow-go v0.6.1-0.20240212202512-715955f1e069 +require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 require ( github.com/golang/protobuf v1.5.3 // indirect diff --git a/pkg/sinker/examples/log/go.sum b/pkg/sinker/examples/log/go.sum index dd3945cb..77fd11a5 100644 --- a/pkg/sinker/examples/log/go.sum +++ b/pkg/sinker/examples/log/go.sum @@ -4,8 +4,8 @@ github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= -github.com/numaproj/numaflow-go v0.6.1-0.20240212202512-715955f1e069 h1:LBMIrUytoxuZazEnwxo+WPAxjHL1rrVhphTyByLiDYY= -github.com/numaproj/numaflow-go v0.6.1-0.20240212202512-715955f1e069/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= +github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 h1:yY1ZjhfqdxE9H4T9YRff+GJHilv9CJgslWEYfsE/EPo= +github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk= golang.org/x/net v0.9.0 h1:aWJ/m6xSmxWBx+V0XRHTlrYrPG56jKsLdTFmsSsCzOM= diff --git a/pkg/sourcer/examples/simple_source/go.mod b/pkg/sourcer/examples/simple_source/go.mod index eda575ea..3c6dd241 100644 --- a/pkg/sourcer/examples/simple_source/go.mod +++ b/pkg/sourcer/examples/simple_source/go.mod @@ -3,7 +3,7 @@ module simple_source go 1.20 require ( - github.com/numaproj/numaflow-go v0.6.1-0.20240212202512-715955f1e069 + github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 github.com/stretchr/testify v1.8.1 ) diff --git a/pkg/sourcer/examples/simple_source/go.sum b/pkg/sourcer/examples/simple_source/go.sum index edd3216e..b4ac8443 100644 --- a/pkg/sourcer/examples/simple_source/go.sum +++ b/pkg/sourcer/examples/simple_source/go.sum @@ -10,8 +10,8 @@ github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE= github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY= github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE= -github.com/numaproj/numaflow-go v0.6.1-0.20240212202512-715955f1e069 h1:LBMIrUytoxuZazEnwxo+WPAxjHL1rrVhphTyByLiDYY= -github.com/numaproj/numaflow-go v0.6.1-0.20240212202512-715955f1e069/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= +github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 h1:yY1ZjhfqdxE9H4T9YRff+GJHilv9CJgslWEYfsE/EPo= +github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= github.com/rogpeppe/go-internal v1.12.0 h1:exVL4IDcn6na9z1rAb56Vxr+CgyK3nn3O+epU5NdKM8= diff --git a/pkg/sourcetransformer/examples/assign_event_time/go.mod b/pkg/sourcetransformer/examples/assign_event_time/go.mod index 21f42aa5..a0dfbaf2 100644 --- a/pkg/sourcetransformer/examples/assign_event_time/go.mod +++ b/pkg/sourcetransformer/examples/assign_event_time/go.mod @@ -2,7 +2,7 @@ module assign_event_time go 1.20 -require github.com/numaproj/numaflow-go v0.6.0 +require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 require ( github.com/golang/protobuf v1.5.3 // indirect diff --git a/pkg/sourcetransformer/examples/assign_event_time/go.sum b/pkg/sourcetransformer/examples/assign_event_time/go.sum index 8b1ed758..77fd11a5 100644 --- a/pkg/sourcetransformer/examples/assign_event_time/go.sum +++ b/pkg/sourcetransformer/examples/assign_event_time/go.sum @@ -4,8 +4,8 @@ github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= -github.com/numaproj/numaflow-go v0.6.0 h1:gqTX1u1pFJJhX/3l3zYM8aLqRSHEainYrgBIollL0js= -github.com/numaproj/numaflow-go v0.6.0/go.mod h1:5zwvvREIbqaCPCKsNE1MVjVToD0kvkCh2Z90Izlhw5U= +github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 h1:yY1ZjhfqdxE9H4T9YRff+GJHilv9CJgslWEYfsE/EPo= +github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk= golang.org/x/net v0.9.0 h1:aWJ/m6xSmxWBx+V0XRHTlrYrPG56jKsLdTFmsSsCzOM= diff --git a/pkg/sourcetransformer/examples/event_time_filter/go.mod b/pkg/sourcetransformer/examples/event_time_filter/go.mod index 9536879a..bc046805 100644 --- a/pkg/sourcetransformer/examples/event_time_filter/go.mod +++ b/pkg/sourcetransformer/examples/event_time_filter/go.mod @@ -3,7 +3,7 @@ module event_time_filter go 1.20 require ( - github.com/numaproj/numaflow-go v0.6.1-0.20240212202512-715955f1e069 + github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 github.com/stretchr/testify v1.8.1 ) diff --git a/pkg/sourcetransformer/examples/event_time_filter/go.sum b/pkg/sourcetransformer/examples/event_time_filter/go.sum index e8805fbb..c84575f5 100644 --- a/pkg/sourcetransformer/examples/event_time_filter/go.sum +++ b/pkg/sourcetransformer/examples/event_time_filter/go.sum @@ -10,8 +10,8 @@ github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE= github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY= github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE= -github.com/numaproj/numaflow-go v0.6.1-0.20240212202512-715955f1e069 h1:LBMIrUytoxuZazEnwxo+WPAxjHL1rrVhphTyByLiDYY= -github.com/numaproj/numaflow-go v0.6.1-0.20240212202512-715955f1e069/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= +github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 h1:yY1ZjhfqdxE9H4T9YRff+GJHilv9CJgslWEYfsE/EPo= +github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= github.com/rogpeppe/go-internal v1.11.0 h1:cWPaGQEPrBb5/AsnsZesgZZ9yb1OQ+GOISoDNXVBh4M= diff --git a/update-sdk-version.sh b/update-sdk-version.sh new file mode 100755 index 00000000..3123f69b --- /dev/null +++ b/update-sdk-version.sh @@ -0,0 +1,21 @@ +#!/bin/bash + +commit_sha=$1 + +find pkg -name "go.mod" | while read -r line; +do + dir="$(dirname "${line}")" + cd "$dir" || exit + + if ! go get github.com/numaproj/numaflow-go@"$commit_sha"; then + echo "Failed to fetch latest SDK version in directory $dir" + exit 1 + fi + + if ! go mod tidy; then + echo "Failed to run go mod tidy in directory $dir" + exit 1 + fi + + cd ~- || exit +done From a4b6c15db990c1d76def953c9dcf59fc63e1e3ea Mon Sep 17 00:00:00 2001 From: a3hadi Date: Tue, 5 Mar 2024 16:48:47 -0500 Subject: [PATCH 07/15] switch to local references Signed-off-by: a3hadi --- pkg/mapper/examples/even_odd/Makefile | 2 +- pkg/mapper/examples/flatmap/Makefile | 2 +- pkg/mapper/examples/flatmap/go.mod | 2 ++ pkg/mapper/examples/flatmap/go.sum | 2 -- pkg/mapper/examples/forward_message/Makefile | 2 +- pkg/mapper/examples/forward_message/go.mod | 2 ++ pkg/mapper/examples/forward_message/go.sum | 2 -- pkg/mapper/examples/retry/Makefile | 2 +- pkg/mapper/examples/retry/go.mod | 2 ++ pkg/mapper/examples/retry/go.sum | 2 -- pkg/mapper/examples/tickgen/Makefile | 2 +- pkg/mapper/examples/tickgen/go.mod | 2 ++ pkg/mapper/examples/tickgen/go.sum | 2 -- pkg/mapstreamer/examples/flatmap_stream/Makefile | 2 +- pkg/mapstreamer/examples/flatmap_stream/go.mod | 2 ++ pkg/mapstreamer/examples/flatmap_stream/go.sum | 2 -- pkg/reducer/examples/counter/Makefile | 2 +- pkg/reducer/examples/counter/go.mod | 2 ++ pkg/reducer/examples/counter/go.sum | 2 -- pkg/reducer/examples/sum/Makefile | 2 +- pkg/reducer/examples/sum/go.mod | 2 ++ pkg/reducer/examples/sum/go.sum | 2 -- pkg/reducestreamer/examples/counter/Makefile | 2 +- pkg/reducestreamer/examples/counter/go.mod | 2 ++ pkg/reducestreamer/examples/counter/go.sum | 2 -- pkg/reducestreamer/examples/sum/Makefile | 2 +- pkg/reducestreamer/examples/sum/go.mod | 2 ++ pkg/reducestreamer/examples/sum/go.sum | 2 -- pkg/sessionreducer/examples/counter/Makefile | 2 +- pkg/sessionreducer/examples/counter/go.mod | 2 ++ pkg/sessionreducer/examples/counter/go.sum | 2 -- pkg/sideinput/examples/simple-sideinput/Makefile | 2 +- pkg/sideinput/examples/simple-sideinput/go.mod | 2 ++ pkg/sideinput/examples/simple-sideinput/go.sum | 2 -- pkg/sideinput/examples/simple-sideinput/udf/Makefile | 2 +- pkg/sideinput/examples/simple-sideinput/udf/go.mod | 2 ++ pkg/sideinput/examples/simple-sideinput/udf/go.sum | 2 -- pkg/sinker/examples/log/Makefile | 2 +- pkg/sinker/examples/log/go.mod | 2 ++ pkg/sinker/examples/log/go.sum | 2 -- pkg/sourcer/examples/simple_source/Makefile | 2 +- pkg/sourcer/examples/simple_source/go.mod | 2 ++ pkg/sourcer/examples/simple_source/go.sum | 2 -- pkg/sourcetransformer/examples/assign_event_time/Makefile | 2 +- pkg/sourcetransformer/examples/assign_event_time/go.mod | 2 ++ pkg/sourcetransformer/examples/assign_event_time/go.sum | 2 -- pkg/sourcetransformer/examples/event_time_filter/Makefile | 2 +- pkg/sourcetransformer/examples/event_time_filter/go.mod | 2 ++ pkg/sourcetransformer/examples/event_time_filter/go.sum | 2 -- 49 files changed, 49 insertions(+), 49 deletions(-) diff --git a/pkg/mapper/examples/even_odd/Makefile b/pkg/mapper/examples/even_odd/Makefile index 4a12dee4..87609b7d 100644 --- a/pkg/mapper/examples/even_odd/Makefile +++ b/pkg/mapper/examples/even_odd/Makefile @@ -4,7 +4,7 @@ build: .PHONY: image image: build - docker build -t "quay.io/numaio/numaflow-go/map-even-odd:v0.6.1" --target even-odd . + docker build -t "quay.io/numaio/numaflow-go/map-even-odd:stable" --target even-odd . clean: -rm -rf ./dist diff --git a/pkg/mapper/examples/flatmap/Makefile b/pkg/mapper/examples/flatmap/Makefile index 872a8283..87a75e8a 100644 --- a/pkg/mapper/examples/flatmap/Makefile +++ b/pkg/mapper/examples/flatmap/Makefile @@ -4,7 +4,7 @@ build: .PHONY: image image: build - docker build -t "quay.io/numaio/numaflow-go/map-flatmap:v0.6.1" --target flatmap . + docker build -t "quay.io/numaio/numaflow-go/map-flatmap:stable" --target flatmap . clean: -rm -rf ./dist diff --git a/pkg/mapper/examples/flatmap/go.mod b/pkg/mapper/examples/flatmap/go.mod index 12d2c1a8..9cdf1b23 100644 --- a/pkg/mapper/examples/flatmap/go.mod +++ b/pkg/mapper/examples/flatmap/go.mod @@ -2,6 +2,8 @@ module flatmap go 1.20 +replace github.com/numaproj/numaflow-go => ../../../../../numaflow-go + require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 require ( diff --git a/pkg/mapper/examples/flatmap/go.sum b/pkg/mapper/examples/flatmap/go.sum index 77fd11a5..95c8479a 100644 --- a/pkg/mapper/examples/flatmap/go.sum +++ b/pkg/mapper/examples/flatmap/go.sum @@ -4,8 +4,6 @@ github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= -github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 h1:yY1ZjhfqdxE9H4T9YRff+GJHilv9CJgslWEYfsE/EPo= -github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk= golang.org/x/net v0.9.0 h1:aWJ/m6xSmxWBx+V0XRHTlrYrPG56jKsLdTFmsSsCzOM= diff --git a/pkg/mapper/examples/forward_message/Makefile b/pkg/mapper/examples/forward_message/Makefile index d9646043..67ee2531 100644 --- a/pkg/mapper/examples/forward_message/Makefile +++ b/pkg/mapper/examples/forward_message/Makefile @@ -4,7 +4,7 @@ build: .PHONY: image image: build - docker build -t "quay.io/numaio/numaflow-go/map-forward-message:v0.6.0" --target forward-message . + docker build -t "quay.io/numaio/numaflow-go/map-forward-message:stable" --target forward-message . clean: -rm -rf ./dist diff --git a/pkg/mapper/examples/forward_message/go.mod b/pkg/mapper/examples/forward_message/go.mod index ea43aab5..139fd86f 100644 --- a/pkg/mapper/examples/forward_message/go.mod +++ b/pkg/mapper/examples/forward_message/go.mod @@ -2,6 +2,8 @@ module even_odd go 1.20 +replace github.com/numaproj/numaflow-go => ../../../../../numaflow-go + require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 require ( diff --git a/pkg/mapper/examples/forward_message/go.sum b/pkg/mapper/examples/forward_message/go.sum index 77fd11a5..95c8479a 100644 --- a/pkg/mapper/examples/forward_message/go.sum +++ b/pkg/mapper/examples/forward_message/go.sum @@ -4,8 +4,6 @@ github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= -github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 h1:yY1ZjhfqdxE9H4T9YRff+GJHilv9CJgslWEYfsE/EPo= -github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk= golang.org/x/net v0.9.0 h1:aWJ/m6xSmxWBx+V0XRHTlrYrPG56jKsLdTFmsSsCzOM= diff --git a/pkg/mapper/examples/retry/Makefile b/pkg/mapper/examples/retry/Makefile index 96700aa7..bdd63e02 100644 --- a/pkg/mapper/examples/retry/Makefile +++ b/pkg/mapper/examples/retry/Makefile @@ -4,7 +4,7 @@ build: .PHONY: image image: build - docker build -t "quay.io/numaio/numaflow-go/map-retry:v0.6.1" --target retry . + docker build -t "quay.io/numaio/numaflow-go/map-retry:stable" --target retry . clean: -rm -rf ./dist diff --git a/pkg/mapper/examples/retry/go.mod b/pkg/mapper/examples/retry/go.mod index 4baf8336..b7fadbdd 100644 --- a/pkg/mapper/examples/retry/go.mod +++ b/pkg/mapper/examples/retry/go.mod @@ -2,6 +2,8 @@ module retry go 1.20 +replace github.com/numaproj/numaflow-go => ../../../../../numaflow-go + require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 require ( diff --git a/pkg/mapper/examples/retry/go.sum b/pkg/mapper/examples/retry/go.sum index 77fd11a5..95c8479a 100644 --- a/pkg/mapper/examples/retry/go.sum +++ b/pkg/mapper/examples/retry/go.sum @@ -4,8 +4,6 @@ github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= -github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 h1:yY1ZjhfqdxE9H4T9YRff+GJHilv9CJgslWEYfsE/EPo= -github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk= golang.org/x/net v0.9.0 h1:aWJ/m6xSmxWBx+V0XRHTlrYrPG56jKsLdTFmsSsCzOM= diff --git a/pkg/mapper/examples/tickgen/Makefile b/pkg/mapper/examples/tickgen/Makefile index dcaf1b85..34580b90 100644 --- a/pkg/mapper/examples/tickgen/Makefile +++ b/pkg/mapper/examples/tickgen/Makefile @@ -4,7 +4,7 @@ build: .PHONY: image image: build - docker build -t "quay.io/numaio/numaflow-go/map-tickgen:v0.6.0" --target tickgen . + docker build -t "quay.io/numaio/numaflow-go/map-tickgen:stable" --target tickgen . clean: -rm -rf ./dist diff --git a/pkg/mapper/examples/tickgen/go.mod b/pkg/mapper/examples/tickgen/go.mod index 44e3029f..93126134 100644 --- a/pkg/mapper/examples/tickgen/go.mod +++ b/pkg/mapper/examples/tickgen/go.mod @@ -2,6 +2,8 @@ module tickgen go 1.20 +replace github.com/numaproj/numaflow-go => ../../../../../numaflow-go + require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 require ( diff --git a/pkg/mapper/examples/tickgen/go.sum b/pkg/mapper/examples/tickgen/go.sum index 77fd11a5..95c8479a 100644 --- a/pkg/mapper/examples/tickgen/go.sum +++ b/pkg/mapper/examples/tickgen/go.sum @@ -4,8 +4,6 @@ github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= -github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 h1:yY1ZjhfqdxE9H4T9YRff+GJHilv9CJgslWEYfsE/EPo= -github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk= golang.org/x/net v0.9.0 h1:aWJ/m6xSmxWBx+V0XRHTlrYrPG56jKsLdTFmsSsCzOM= diff --git a/pkg/mapstreamer/examples/flatmap_stream/Makefile b/pkg/mapstreamer/examples/flatmap_stream/Makefile index 6e582a32..8f7b8966 100644 --- a/pkg/mapstreamer/examples/flatmap_stream/Makefile +++ b/pkg/mapstreamer/examples/flatmap_stream/Makefile @@ -4,7 +4,7 @@ build: .PHONY: image image: build - docker build -t "quay.io/numaio/numaflow-go/map-flatmap-stream:v0.6.1" --target flatmap_stream . + docker build -t "quay.io/numaio/numaflow-go/map-flatmap-stream:stable" --target flatmap_stream . clean: -rm -rf ./dist diff --git a/pkg/mapstreamer/examples/flatmap_stream/go.mod b/pkg/mapstreamer/examples/flatmap_stream/go.mod index bd46bc21..e4b867a3 100644 --- a/pkg/mapstreamer/examples/flatmap_stream/go.mod +++ b/pkg/mapstreamer/examples/flatmap_stream/go.mod @@ -2,6 +2,8 @@ module flatmap_stream go 1.20 +replace github.com/numaproj/numaflow-go => ../../../../../numaflow-go + require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 require ( diff --git a/pkg/mapstreamer/examples/flatmap_stream/go.sum b/pkg/mapstreamer/examples/flatmap_stream/go.sum index 77fd11a5..95c8479a 100644 --- a/pkg/mapstreamer/examples/flatmap_stream/go.sum +++ b/pkg/mapstreamer/examples/flatmap_stream/go.sum @@ -4,8 +4,6 @@ github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= -github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 h1:yY1ZjhfqdxE9H4T9YRff+GJHilv9CJgslWEYfsE/EPo= -github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk= golang.org/x/net v0.9.0 h1:aWJ/m6xSmxWBx+V0XRHTlrYrPG56jKsLdTFmsSsCzOM= diff --git a/pkg/reducer/examples/counter/Makefile b/pkg/reducer/examples/counter/Makefile index a757ae4b..b04f0ace 100644 --- a/pkg/reducer/examples/counter/Makefile +++ b/pkg/reducer/examples/counter/Makefile @@ -4,7 +4,7 @@ build: .PHONY: image image: build - docker build -t "quay.io/numaio/numaflow-go/reduce-counter:v0.6.1" --target counter . + docker build -t "quay.io/numaio/numaflow-go/reduce-counter:stable" --target counter . clean: -rm -rf ./dist diff --git a/pkg/reducer/examples/counter/go.mod b/pkg/reducer/examples/counter/go.mod index 96927fbd..a5d7db1c 100644 --- a/pkg/reducer/examples/counter/go.mod +++ b/pkg/reducer/examples/counter/go.mod @@ -2,6 +2,8 @@ module counter go 1.20 +replace github.com/numaproj/numaflow-go => ../../../../../numaflow-go + require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 require ( diff --git a/pkg/reducer/examples/counter/go.sum b/pkg/reducer/examples/counter/go.sum index 727ad275..ab002170 100644 --- a/pkg/reducer/examples/counter/go.sum +++ b/pkg/reducer/examples/counter/go.sum @@ -4,8 +4,6 @@ github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= -github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 h1:yY1ZjhfqdxE9H4T9YRff+GJHilv9CJgslWEYfsE/EPo= -github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk= golang.org/x/net v0.9.0 h1:aWJ/m6xSmxWBx+V0XRHTlrYrPG56jKsLdTFmsSsCzOM= diff --git a/pkg/reducer/examples/sum/Makefile b/pkg/reducer/examples/sum/Makefile index 47437cb4..f3e9e8d1 100644 --- a/pkg/reducer/examples/sum/Makefile +++ b/pkg/reducer/examples/sum/Makefile @@ -4,7 +4,7 @@ build: .PHONY: image image: build - docker build -t "quay.io/numaio/numaflow-go/reduce-sum:v0.6.1" --target sum . + docker build -t "quay.io/numaio/numaflow-go/reduce-sum:stable" --target sum . clean: -rm -rf ./dist diff --git a/pkg/reducer/examples/sum/go.mod b/pkg/reducer/examples/sum/go.mod index e8aff403..d84a1eaf 100644 --- a/pkg/reducer/examples/sum/go.mod +++ b/pkg/reducer/examples/sum/go.mod @@ -2,6 +2,8 @@ module sum go 1.20 +replace github.com/numaproj/numaflow-go => ../../../../../numaflow-go + require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 require ( diff --git a/pkg/reducer/examples/sum/go.sum b/pkg/reducer/examples/sum/go.sum index 727ad275..ab002170 100644 --- a/pkg/reducer/examples/sum/go.sum +++ b/pkg/reducer/examples/sum/go.sum @@ -4,8 +4,6 @@ github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= -github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 h1:yY1ZjhfqdxE9H4T9YRff+GJHilv9CJgslWEYfsE/EPo= -github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk= golang.org/x/net v0.9.0 h1:aWJ/m6xSmxWBx+V0XRHTlrYrPG56jKsLdTFmsSsCzOM= diff --git a/pkg/reducestreamer/examples/counter/Makefile b/pkg/reducestreamer/examples/counter/Makefile index ffe3036c..bc6e4c4d 100644 --- a/pkg/reducestreamer/examples/counter/Makefile +++ b/pkg/reducestreamer/examples/counter/Makefile @@ -4,7 +4,7 @@ build: .PHONY: image image: build - docker build -t "quay.io/numaio/numaflow-go/reduce-stream-counter:v0.5.3" --target counter . + docker build -t "quay.io/numaio/numaflow-go/reduce-stream-counter:stable" --target counter . clean: -rm -rf ./dist diff --git a/pkg/reducestreamer/examples/counter/go.mod b/pkg/reducestreamer/examples/counter/go.mod index 96927fbd..a5d7db1c 100644 --- a/pkg/reducestreamer/examples/counter/go.mod +++ b/pkg/reducestreamer/examples/counter/go.mod @@ -2,6 +2,8 @@ module counter go 1.20 +replace github.com/numaproj/numaflow-go => ../../../../../numaflow-go + require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 require ( diff --git a/pkg/reducestreamer/examples/counter/go.sum b/pkg/reducestreamer/examples/counter/go.sum index 727ad275..ab002170 100644 --- a/pkg/reducestreamer/examples/counter/go.sum +++ b/pkg/reducestreamer/examples/counter/go.sum @@ -4,8 +4,6 @@ github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= -github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 h1:yY1ZjhfqdxE9H4T9YRff+GJHilv9CJgslWEYfsE/EPo= -github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk= golang.org/x/net v0.9.0 h1:aWJ/m6xSmxWBx+V0XRHTlrYrPG56jKsLdTFmsSsCzOM= diff --git a/pkg/reducestreamer/examples/sum/Makefile b/pkg/reducestreamer/examples/sum/Makefile index d2bbf56e..9cf335b6 100644 --- a/pkg/reducestreamer/examples/sum/Makefile +++ b/pkg/reducestreamer/examples/sum/Makefile @@ -4,7 +4,7 @@ build: .PHONY: image image: build - docker build -t "quay.io/numaio/numaflow-go/reduce-stream-sum:v0.6.1" --target sum . + docker build -t "quay.io/numaio/numaflow-go/reduce-stream-sum:stable" --target sum . clean: -rm -rf ./dist diff --git a/pkg/reducestreamer/examples/sum/go.mod b/pkg/reducestreamer/examples/sum/go.mod index e8aff403..d84a1eaf 100644 --- a/pkg/reducestreamer/examples/sum/go.mod +++ b/pkg/reducestreamer/examples/sum/go.mod @@ -2,6 +2,8 @@ module sum go 1.20 +replace github.com/numaproj/numaflow-go => ../../../../../numaflow-go + require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 require ( diff --git a/pkg/reducestreamer/examples/sum/go.sum b/pkg/reducestreamer/examples/sum/go.sum index 727ad275..ab002170 100644 --- a/pkg/reducestreamer/examples/sum/go.sum +++ b/pkg/reducestreamer/examples/sum/go.sum @@ -4,8 +4,6 @@ github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= -github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 h1:yY1ZjhfqdxE9H4T9YRff+GJHilv9CJgslWEYfsE/EPo= -github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk= golang.org/x/net v0.9.0 h1:aWJ/m6xSmxWBx+V0XRHTlrYrPG56jKsLdTFmsSsCzOM= diff --git a/pkg/sessionreducer/examples/counter/Makefile b/pkg/sessionreducer/examples/counter/Makefile index eb4555da..19c37944 100644 --- a/pkg/sessionreducer/examples/counter/Makefile +++ b/pkg/sessionreducer/examples/counter/Makefile @@ -4,7 +4,7 @@ build: .PHONY: image image: build - docker build -t "quay.io/numaio/numaflow-go/session-counter:v0.6.1" --target counter . + docker build -t "quay.io/numaio/numaflow-go/session-counter:stable" --target counter . clean: -rm -rf ./dist diff --git a/pkg/sessionreducer/examples/counter/go.mod b/pkg/sessionreducer/examples/counter/go.mod index c416c1cf..408225ac 100644 --- a/pkg/sessionreducer/examples/counter/go.mod +++ b/pkg/sessionreducer/examples/counter/go.mod @@ -2,6 +2,8 @@ module counter go 1.20 +replace github.com/numaproj/numaflow-go => ../../../../../numaflow-go + require ( github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 go.uber.org/atomic v1.11.0 diff --git a/pkg/sessionreducer/examples/counter/go.sum b/pkg/sessionreducer/examples/counter/go.sum index 393c6c5c..e5697aab 100644 --- a/pkg/sessionreducer/examples/counter/go.sum +++ b/pkg/sessionreducer/examples/counter/go.sum @@ -4,8 +4,6 @@ github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= -github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 h1:yY1ZjhfqdxE9H4T9YRff+GJHilv9CJgslWEYfsE/EPo= -github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk= go.uber.org/atomic v1.11.0 h1:ZvwS0R+56ePWxUNi+Atn9dWONBPp/AUETXlHW0DxSjE= diff --git a/pkg/sideinput/examples/simple-sideinput/Makefile b/pkg/sideinput/examples/simple-sideinput/Makefile index 97db7739..21426717 100644 --- a/pkg/sideinput/examples/simple-sideinput/Makefile +++ b/pkg/sideinput/examples/simple-sideinput/Makefile @@ -4,7 +4,7 @@ build: .PHONY: image image: build - docker buildx build -t "quay.io/numaio/numaflow-go/sideinput-example:v0.6.0" --platform linux/amd64,linux/arm64 --target sideinput . --push + docker buildx build -t "quay.io/numaio/numaflow-go/sideinput-example:stable" --platform linux/amd64,linux/arm64 --target sideinput . --push clean: -rm -rf ./dist diff --git a/pkg/sideinput/examples/simple-sideinput/go.mod b/pkg/sideinput/examples/simple-sideinput/go.mod index 541837d4..544d8199 100644 --- a/pkg/sideinput/examples/simple-sideinput/go.mod +++ b/pkg/sideinput/examples/simple-sideinput/go.mod @@ -2,6 +2,8 @@ module sideinput go 1.20 +replace github.com/numaproj/numaflow-go => ../../../../../numaflow-go + require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 require ( diff --git a/pkg/sideinput/examples/simple-sideinput/go.sum b/pkg/sideinput/examples/simple-sideinput/go.sum index 77fd11a5..95c8479a 100644 --- a/pkg/sideinput/examples/simple-sideinput/go.sum +++ b/pkg/sideinput/examples/simple-sideinput/go.sum @@ -4,8 +4,6 @@ github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= -github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 h1:yY1ZjhfqdxE9H4T9YRff+GJHilv9CJgslWEYfsE/EPo= -github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk= golang.org/x/net v0.9.0 h1:aWJ/m6xSmxWBx+V0XRHTlrYrPG56jKsLdTFmsSsCzOM= diff --git a/pkg/sideinput/examples/simple-sideinput/udf/Makefile b/pkg/sideinput/examples/simple-sideinput/udf/Makefile index 688d5f51..eb1456c0 100644 --- a/pkg/sideinput/examples/simple-sideinput/udf/Makefile +++ b/pkg/sideinput/examples/simple-sideinput/udf/Makefile @@ -5,7 +5,7 @@ build: .PHONY: image #To build an image that supports multiple platforms(linux/amd64,linux/arm64) and push to quay.io, use the following command image: build - docker buildx build -t "quay.io/numaio/numaflow-go/udf-sideinput-example:v0.6.0" --platform linux/amd64,linux/arm64 --target udf-sideinput . --push + docker buildx build -t "quay.io/numaio/numaflow-go/udf-sideinput-example:stable" --platform linux/amd64,linux/arm64 --target udf-sideinput . --push diff --git a/pkg/sideinput/examples/simple-sideinput/udf/go.mod b/pkg/sideinput/examples/simple-sideinput/udf/go.mod index ef03b57a..51c4d002 100644 --- a/pkg/sideinput/examples/simple-sideinput/udf/go.mod +++ b/pkg/sideinput/examples/simple-sideinput/udf/go.mod @@ -2,6 +2,8 @@ module even_odd go 1.20 +replace github.com/numaproj/numaflow-go => ../../../../../../numaflow-go + require ( github.com/fsnotify/fsnotify v1.6.0 github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 diff --git a/pkg/sideinput/examples/simple-sideinput/udf/go.sum b/pkg/sideinput/examples/simple-sideinput/udf/go.sum index e747e57f..bfde5735 100644 --- a/pkg/sideinput/examples/simple-sideinput/udf/go.sum +++ b/pkg/sideinput/examples/simple-sideinput/udf/go.sum @@ -6,8 +6,6 @@ github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= -github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 h1:yY1ZjhfqdxE9H4T9YRff+GJHilv9CJgslWEYfsE/EPo= -github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk= golang.org/x/net v0.9.0 h1:aWJ/m6xSmxWBx+V0XRHTlrYrPG56jKsLdTFmsSsCzOM= diff --git a/pkg/sinker/examples/log/Makefile b/pkg/sinker/examples/log/Makefile index 658ac873..37e42e94 100644 --- a/pkg/sinker/examples/log/Makefile +++ b/pkg/sinker/examples/log/Makefile @@ -4,7 +4,7 @@ build: .PHONY: image image: build - docker build -t "quay.io/numaio/numaflow-go/sink-log:v0.6.1" --target log . + docker build -t "quay.io/numaio/numaflow-go/sink-log:stable" --target log . clean: -rm -rf ./dist diff --git a/pkg/sinker/examples/log/go.mod b/pkg/sinker/examples/log/go.mod index 938fe1f2..af7b8d2c 100644 --- a/pkg/sinker/examples/log/go.mod +++ b/pkg/sinker/examples/log/go.mod @@ -2,6 +2,8 @@ module log_sink go 1.20 +replace github.com/numaproj/numaflow-go => ../../../../../numaflow-go + require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 require ( diff --git a/pkg/sinker/examples/log/go.sum b/pkg/sinker/examples/log/go.sum index 77fd11a5..95c8479a 100644 --- a/pkg/sinker/examples/log/go.sum +++ b/pkg/sinker/examples/log/go.sum @@ -4,8 +4,6 @@ github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= -github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 h1:yY1ZjhfqdxE9H4T9YRff+GJHilv9CJgslWEYfsE/EPo= -github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk= golang.org/x/net v0.9.0 h1:aWJ/m6xSmxWBx+V0XRHTlrYrPG56jKsLdTFmsSsCzOM= diff --git a/pkg/sourcer/examples/simple_source/Makefile b/pkg/sourcer/examples/simple_source/Makefile index ec7ccab7..61c35287 100644 --- a/pkg/sourcer/examples/simple_source/Makefile +++ b/pkg/sourcer/examples/simple_source/Makefile @@ -4,7 +4,7 @@ build: .PHONY: image image: build - docker build -t "quay.io/numaio/numaflow-go/source-simple-source:v0.6.1" --target simple-source . + docker build -t "quay.io/numaio/numaflow-go/source-simple-source:stable" --target simple-source . clean: -rm -rf ./dist diff --git a/pkg/sourcer/examples/simple_source/go.mod b/pkg/sourcer/examples/simple_source/go.mod index 3c6dd241..167f6b05 100644 --- a/pkg/sourcer/examples/simple_source/go.mod +++ b/pkg/sourcer/examples/simple_source/go.mod @@ -2,6 +2,8 @@ module simple_source go 1.20 +replace github.com/numaproj/numaflow-go => ../../../../../numaflow-go + require ( github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 github.com/stretchr/testify v1.8.1 diff --git a/pkg/sourcer/examples/simple_source/go.sum b/pkg/sourcer/examples/simple_source/go.sum index b4ac8443..0eb6ac02 100644 --- a/pkg/sourcer/examples/simple_source/go.sum +++ b/pkg/sourcer/examples/simple_source/go.sum @@ -10,8 +10,6 @@ github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE= github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY= github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE= -github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 h1:yY1ZjhfqdxE9H4T9YRff+GJHilv9CJgslWEYfsE/EPo= -github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= github.com/rogpeppe/go-internal v1.12.0 h1:exVL4IDcn6na9z1rAb56Vxr+CgyK3nn3O+epU5NdKM8= diff --git a/pkg/sourcetransformer/examples/assign_event_time/Makefile b/pkg/sourcetransformer/examples/assign_event_time/Makefile index 5b6c5a68..34a183ef 100644 --- a/pkg/sourcetransformer/examples/assign_event_time/Makefile +++ b/pkg/sourcetransformer/examples/assign_event_time/Makefile @@ -4,7 +4,7 @@ build: .PHONY: image image: build - docker build -t "quay.io/numaio/numaflow-go/mapt-assign-event-time:v0.6.0" --target assign-event-time . + docker build -t "quay.io/numaio/numaflow-go/mapt-assign-event-time:stable" --target assign-event-time . clean: -rm -rf ./dist diff --git a/pkg/sourcetransformer/examples/assign_event_time/go.mod b/pkg/sourcetransformer/examples/assign_event_time/go.mod index a0dfbaf2..0bfaec40 100644 --- a/pkg/sourcetransformer/examples/assign_event_time/go.mod +++ b/pkg/sourcetransformer/examples/assign_event_time/go.mod @@ -2,6 +2,8 @@ module assign_event_time go 1.20 +replace github.com/numaproj/numaflow-go => ../../../../../numaflow-go + require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 require ( diff --git a/pkg/sourcetransformer/examples/assign_event_time/go.sum b/pkg/sourcetransformer/examples/assign_event_time/go.sum index 77fd11a5..95c8479a 100644 --- a/pkg/sourcetransformer/examples/assign_event_time/go.sum +++ b/pkg/sourcetransformer/examples/assign_event_time/go.sum @@ -4,8 +4,6 @@ github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= -github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 h1:yY1ZjhfqdxE9H4T9YRff+GJHilv9CJgslWEYfsE/EPo= -github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk= golang.org/x/net v0.9.0 h1:aWJ/m6xSmxWBx+V0XRHTlrYrPG56jKsLdTFmsSsCzOM= diff --git a/pkg/sourcetransformer/examples/event_time_filter/Makefile b/pkg/sourcetransformer/examples/event_time_filter/Makefile index 0dc50ba6..b94f3144 100644 --- a/pkg/sourcetransformer/examples/event_time_filter/Makefile +++ b/pkg/sourcetransformer/examples/event_time_filter/Makefile @@ -4,7 +4,7 @@ build: .PHONY: image image: build - docker build -t "quay.io/numaio/numaflow-go/mapt-event-time-filter:v0.6.1" --target event-time-filter . + docker build -t "quay.io/numaio/numaflow-go/mapt-event-time-filter:stable" --target event-time-filter . clean: -rm -rf ./dist diff --git a/pkg/sourcetransformer/examples/event_time_filter/go.mod b/pkg/sourcetransformer/examples/event_time_filter/go.mod index bc046805..09fdf50a 100644 --- a/pkg/sourcetransformer/examples/event_time_filter/go.mod +++ b/pkg/sourcetransformer/examples/event_time_filter/go.mod @@ -2,6 +2,8 @@ module event_time_filter go 1.20 +replace github.com/numaproj/numaflow-go => ../../../../../numaflow-go + require ( github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 github.com/stretchr/testify v1.8.1 diff --git a/pkg/sourcetransformer/examples/event_time_filter/go.sum b/pkg/sourcetransformer/examples/event_time_filter/go.sum index c84575f5..3db6e45f 100644 --- a/pkg/sourcetransformer/examples/event_time_filter/go.sum +++ b/pkg/sourcetransformer/examples/event_time_filter/go.sum @@ -10,8 +10,6 @@ github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE= github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY= github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE= -github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 h1:yY1ZjhfqdxE9H4T9YRff+GJHilv9CJgslWEYfsE/EPo= -github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= github.com/rogpeppe/go-internal v1.11.0 h1:cWPaGQEPrBb5/AsnsZesgZZ9yb1OQ+GOISoDNXVBh4M= From 45a1df46c9a3aa4723b8ec0a3aab8b9690f7e209 Mon Sep 17 00:00:00 2001 From: a3hadi Date: Wed, 6 Mar 2024 09:48:28 -0500 Subject: [PATCH 08/15] remove unecessary workflow Signed-off-by: a3hadi --- .../workflows/update-sdk-dependencies.yaml | 36 ------------------- 1 file changed, 36 deletions(-) delete mode 100644 .github/workflows/update-sdk-dependencies.yaml diff --git a/.github/workflows/update-sdk-dependencies.yaml b/.github/workflows/update-sdk-dependencies.yaml deleted file mode 100644 index 8906a5cc..00000000 --- a/.github/workflows/update-sdk-dependencies.yaml +++ /dev/null @@ -1,36 +0,0 @@ -on: - pull_request: - types: - - closed - paths-ignore: - - "pkg/*/examples/go.sum" - - "pkg/*/examples/go.mod" - - "*.md" - -jobs: - if_merged: - if: github.event.pull_request.merged == true - name: Update Go SDK Version - runs-on: ubuntu-latest - env: - COMMIT_SHA: ${{ github.sha }} # refers to the SHA of the merge commit, not the individual commits in PR - - steps: - - name: Setup Go - uses: actions/setup-go@v4.0.0 - with: - go-version: "1.20" - - name: Checkout code - uses: actions/checkout@v3 # includes the changes from merged PR - - name: Update dependencies - run: ./.github/scripts/traverse-examples.sh "go get github.com/numaproj/numaflow-go@${{ env.COMMIT_SHA }}" "go mod tidy" - - - name: Create PR - uses: peter-evans/create-pull-request@v6 - with: - branch: update-sdk-${{ env.COMMIT_SHA }} - title: "chore: update sdk version" - body: "Modify go.mod and go.sum in the example folders, so that they use an up to date version of the GO SDK" - commit-message: "Update dependency files to point to latest commit of numaflow-go" - base: main - signoff: true From f7742809d43caa7b46a7013f1fcab66dc9f3cb94 Mon Sep 17 00:00:00 2001 From: a3hadi Date: Wed, 6 Mar 2024 13:03:18 -0500 Subject: [PATCH 09/15] modify update script Signed-off-by: a3hadi --- .github/scripts/traverse-examples.sh | 14 ------ .github/workflows/buid-push.yaml | 2 +- update-sdk-version.sh | 21 --------- update_examples.sh | 66 ++++++++++++++++++++++++++++ 4 files changed, 67 insertions(+), 36 deletions(-) delete mode 100755 .github/scripts/traverse-examples.sh delete mode 100755 update-sdk-version.sh create mode 100755 update_examples.sh diff --git a/.github/scripts/traverse-examples.sh b/.github/scripts/traverse-examples.sh deleted file mode 100755 index b455fae3..00000000 --- a/.github/scripts/traverse-examples.sh +++ /dev/null @@ -1,14 +0,0 @@ -#!/bin/bash - -commands=( "$@" ) - -find pkg -name "go.mod" | while read -r line; -do - dir="$(dirname "${line}")" - cd "$dir" || exit - for cmd in "${commands[@]}" - do - eval "$cmd" - done - cd ~- || exit -done diff --git a/.github/workflows/buid-push.yaml b/.github/workflows/buid-push.yaml index e697f7e0..065fba3b 100644 --- a/.github/workflows/buid-push.yaml +++ b/.github/workflows/buid-push.yaml @@ -36,7 +36,7 @@ jobs: username: ${{ env.QUAY_USERNAME }} password: ${{ env.QUAY_PASSWORD }} - name: Build and tag images - run: ./.github/scripts/traverse-examples.sh "make image" + run: ./update_examples --build - name: Push images env: IMAGE_PREFIX: "quay.io/numaio/numaflow-go" diff --git a/update-sdk-version.sh b/update-sdk-version.sh deleted file mode 100755 index 3123f69b..00000000 --- a/update-sdk-version.sh +++ /dev/null @@ -1,21 +0,0 @@ -#!/bin/bash - -commit_sha=$1 - -find pkg -name "go.mod" | while read -r line; -do - dir="$(dirname "${line}")" - cd "$dir" || exit - - if ! go get github.com/numaproj/numaflow-go@"$commit_sha"; then - echo "Failed to fetch latest SDK version in directory $dir" - exit 1 - fi - - if ! go mod tidy; then - echo "Failed to run go mod tidy in directory $dir" - exit 1 - fi - - cd ~- || exit -done diff --git a/update_examples.sh b/update_examples.sh new file mode 100755 index 00000000..f45d8c19 --- /dev/null +++ b/update_examples.sh @@ -0,0 +1,66 @@ +#!/bin/bash + +commit_sha="" + +function show_help () { + echo "Usage: $0 [-h|--help] (-b|--build | -c|--commit-sha )" + echo " -h, --help Display help message and exit" + echo " -b, --build Build the docker images of all the examples" + echo " -c, --commit-sha Update the numaflow-go version to the specified SHA" +} + +function traverse_examples () { + find pkg -name "go.mod" | while read -r line; + do + dir="$(dirname "${line}")" + cd "$dir" || exit + + for command in "$@" + do + if ! $command; then + echo "Error when running $command in $dir" + exit 1 + fi + done + + cd ~- || exit + done +} + +handle_options() { + while [ $# -gt 0 ]; do + case "$1" in + -h | --help) + show_help + exit 0 + ;; + -b | --build) + traverse_examples "make clean" + ;; + -c | --commit-sha) + if [ -z "$2" ]; then + echo "Commit SHA not specified." >&2 + show_help + exit 1 + fi + + commit_sha=$2 + traverse_examples "go get github.com/numaproj/numaflow-go@$commit_sha" "go mod tidy" + shift + ;; + *) + echo "Invalid option: $1" >&2 + show_help + exit 1 + ;; + esac + shift + done +} + +echo "$#" +handle_options "$@" + +if [ -n "$commit_sha" ]; then + echo "Commit SHA specified: $commit_sha" +fi \ No newline at end of file From 30850acc7499b78dfd158eaef68ac0de9fd36f93 Mon Sep 17 00:00:00 2001 From: a3hadi Date: Wed, 6 Mar 2024 13:52:54 -0500 Subject: [PATCH 10/15] added error checking to update script Signed-off-by: a3hadi --- update_examples.sh | 34 ++++++++++++++++++++++++++++------ 1 file changed, 28 insertions(+), 6 deletions(-) diff --git a/update_examples.sh b/update_examples.sh index f45d8c19..cd963d4a 100755 --- a/update_examples.sh +++ b/update_examples.sh @@ -18,7 +18,7 @@ function traverse_examples () { for command in "$@" do if ! $command; then - echo "Error when running $command in $dir" + echo "Error when running $command in $dir" >&2 exit 1 fi done @@ -27,17 +27,27 @@ function traverse_examples () { done } +if [ $# -eq 0 ]; then + echo "Error: provide at least one argument" >&2 + show_help + exit 1 +fi + +usingBuild=0 +usingSHA=0 +usingHelp=0 + handle_options() { while [ $# -gt 0 ]; do case "$1" in -h | --help) - show_help - exit 0 + usingHelp=1 ;; -b | --build) - traverse_examples "make clean" + usingBuild=1 ;; -c | --commit-sha) + usingSHA=1 if [ -z "$2" ]; then echo "Commit SHA not specified." >&2 show_help @@ -45,7 +55,6 @@ handle_options() { fi commit_sha=$2 - traverse_examples "go get github.com/numaproj/numaflow-go@$commit_sha" "go mod tidy" shift ;; *) @@ -58,9 +67,22 @@ handle_options() { done } -echo "$#" handle_options "$@" +if (( usingBuild + usingSHA + usingHelp > 1 )); then + echo "Only one of '-h', '-b', '-c' is allowed at a time" >&2 + show_help + exit 1 +fi + if [ -n "$commit_sha" ]; then echo "Commit SHA specified: $commit_sha" +fi + +if (( usingBuild )); then + traverse_examples "make clean" +elif (( usingSHA )); then + traverse_examples "go get github.com/numaproj/numaflow-go@$commit_sha" "go mod tidy" +elif (( usingHelp )); then + show_help fi \ No newline at end of file From 041f7f8547a9818b2f60842f7753fc077f77103b Mon Sep 17 00:00:00 2001 From: a3hadi Date: Wed, 6 Mar 2024 13:54:52 -0500 Subject: [PATCH 11/15] change to make image Signed-off-by: a3hadi --- update_examples.sh | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/update_examples.sh b/update_examples.sh index cd963d4a..d7c17b91 100755 --- a/update_examples.sh +++ b/update_examples.sh @@ -80,7 +80,7 @@ if [ -n "$commit_sha" ]; then fi if (( usingBuild )); then - traverse_examples "make clean" + traverse_examples "make image" elif (( usingSHA )); then traverse_examples "go get github.com/numaproj/numaflow-go@$commit_sha" "go mod tidy" elif (( usingHelp )); then From 0024c8e9ca2be6247457ba1a11d37367cc79fb78 Mon Sep 17 00:00:00 2001 From: a3hadi Date: Wed, 6 Mar 2024 14:11:47 -0500 Subject: [PATCH 12/15] implement update script and docker build/push workflow Signed-off-by: a3hadi --- update_examples.sh | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/update_examples.sh b/update_examples.sh index d7c17b91..36d068a1 100755 --- a/update_examples.sh +++ b/update_examples.sh @@ -85,4 +85,4 @@ elif (( usingSHA )); then traverse_examples "go get github.com/numaproj/numaflow-go@$commit_sha" "go mod tidy" elif (( usingHelp )); then show_help -fi \ No newline at end of file +fi From ed55bda4dd9691b7fc796243bf9ecc43c577b7c2 Mon Sep 17 00:00:00 2001 From: a3hadi Date: Wed, 6 Mar 2024 14:25:37 -0500 Subject: [PATCH 13/15] modify update script Signed-off-by: a3hadi --- update_examples.sh | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/update_examples.sh b/update_examples.sh index 36d068a1..3bff9f3d 100755 --- a/update_examples.sh +++ b/update_examples.sh @@ -1,7 +1,5 @@ #!/bin/bash -commit_sha="" - function show_help () { echo "Usage: $0 [-h|--help] (-b|--build | -c|--commit-sha )" echo " -h, --help Display help message and exit" @@ -33,9 +31,10 @@ if [ $# -eq 0 ]; then exit 1 fi +usingHelp=0 usingBuild=0 usingSHA=0 -usingHelp=0 +commit_sha="" handle_options() { while [ $# -gt 0 ]; do From b16065638c7ae0baa0f91749ba84b0daef2c9371 Mon Sep 17 00:00:00 2001 From: a3hadi Date: Wed, 6 Mar 2024 14:27:00 -0500 Subject: [PATCH 14/15] modify update script Signed-off-by: a3hadi --- update_examples.sh | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/update_examples.sh b/update_examples.sh index 3bff9f3d..a9d86cf0 100755 --- a/update_examples.sh +++ b/update_examples.sh @@ -36,7 +36,7 @@ usingBuild=0 usingSHA=0 commit_sha="" -handle_options() { +function handle_options () { while [ $# -gt 0 ]; do case "$1" in -h | --help) From cdfd1c6750a363c6d3fa7b2707342d5ee2f51d8c Mon Sep 17 00:00:00 2001 From: Abdullah Yildirim Date: Thu, 7 Mar 2024 11:50:21 -0500 Subject: [PATCH 15/15] Update update_examples.sh Co-authored-by: Keran Yang --- update_examples.sh | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/update_examples.sh b/update_examples.sh index a9d86cf0..143a57a4 100755 --- a/update_examples.sh +++ b/update_examples.sh @@ -4,7 +4,7 @@ function show_help () { echo "Usage: $0 [-h|--help] (-b|--build | -c|--commit-sha )" echo " -h, --help Display help message and exit" echo " -b, --build Build the docker images of all the examples" - echo " -c, --commit-sha Update the numaflow-go version to the specified SHA" + echo " -c, --commit-sha Update all the examples to depend on the numaflow-go version with the specified SHA" } function traverse_examples () {