diff --git a/pkg/mapper/examples/flatmap/go.mod b/pkg/mapper/examples/flatmap/go.mod index 9cdf1b23..c16fc9dd 100644 --- a/pkg/mapper/examples/flatmap/go.mod +++ b/pkg/mapper/examples/flatmap/go.mod @@ -2,7 +2,7 @@ module flatmap go 1.20 -replace github.com/numaproj/numaflow-go => ../../../../../numaflow-go +replace github.com/numaproj/numaflow-go => ../../../.. require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 diff --git a/pkg/mapper/examples/forward_message/go.mod b/pkg/mapper/examples/forward_message/go.mod index 139fd86f..1e27d242 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 -replace github.com/numaproj/numaflow-go => ../../../../../numaflow-go +replace github.com/numaproj/numaflow-go => ../../../.. require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 diff --git a/pkg/mapper/examples/retry/go.mod b/pkg/mapper/examples/retry/go.mod index b7fadbdd..809603ac 100644 --- a/pkg/mapper/examples/retry/go.mod +++ b/pkg/mapper/examples/retry/go.mod @@ -2,7 +2,7 @@ module retry go 1.20 -replace github.com/numaproj/numaflow-go => ../../../../../numaflow-go +replace github.com/numaproj/numaflow-go => ../../../.. require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 diff --git a/pkg/mapper/examples/tickgen/go.mod b/pkg/mapper/examples/tickgen/go.mod index 93126134..8e9a570b 100644 --- a/pkg/mapper/examples/tickgen/go.mod +++ b/pkg/mapper/examples/tickgen/go.mod @@ -2,7 +2,7 @@ module tickgen go 1.20 -replace github.com/numaproj/numaflow-go => ../../../../../numaflow-go +replace github.com/numaproj/numaflow-go => ../../../.. require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 diff --git a/pkg/mapstreamer/examples/flatmap_stream/go.mod b/pkg/mapstreamer/examples/flatmap_stream/go.mod index e4b867a3..05f60e9a 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 -replace github.com/numaproj/numaflow-go => ../../../../../numaflow-go +replace github.com/numaproj/numaflow-go => ../../../.. require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 diff --git a/pkg/reducer/examples/counter/go.mod b/pkg/reducer/examples/counter/go.mod index a5d7db1c..a185a623 100644 --- a/pkg/reducer/examples/counter/go.mod +++ b/pkg/reducer/examples/counter/go.mod @@ -2,7 +2,7 @@ module counter go 1.20 -replace github.com/numaproj/numaflow-go => ../../../../../numaflow-go +replace github.com/numaproj/numaflow-go => ../../../.. require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 diff --git a/pkg/reducer/examples/sum/go.mod b/pkg/reducer/examples/sum/go.mod index d84a1eaf..208c27bf 100644 --- a/pkg/reducer/examples/sum/go.mod +++ b/pkg/reducer/examples/sum/go.mod @@ -2,7 +2,7 @@ module sum go 1.20 -replace github.com/numaproj/numaflow-go => ../../../../../numaflow-go +replace github.com/numaproj/numaflow-go => ../../../.. require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 diff --git a/pkg/reducestreamer/examples/counter/go.mod b/pkg/reducestreamer/examples/counter/go.mod index a5d7db1c..a185a623 100644 --- a/pkg/reducestreamer/examples/counter/go.mod +++ b/pkg/reducestreamer/examples/counter/go.mod @@ -2,7 +2,7 @@ module counter go 1.20 -replace github.com/numaproj/numaflow-go => ../../../../../numaflow-go +replace github.com/numaproj/numaflow-go => ../../../.. require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 diff --git a/pkg/reducestreamer/examples/sum/go.mod b/pkg/reducestreamer/examples/sum/go.mod index d84a1eaf..208c27bf 100644 --- a/pkg/reducestreamer/examples/sum/go.mod +++ b/pkg/reducestreamer/examples/sum/go.mod @@ -2,7 +2,7 @@ module sum go 1.20 -replace github.com/numaproj/numaflow-go => ../../../../../numaflow-go +replace github.com/numaproj/numaflow-go => ../../../.. require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 diff --git a/pkg/sessionreducer/examples/counter/go.mod b/pkg/sessionreducer/examples/counter/go.mod index 408225ac..cbce3830 100644 --- a/pkg/sessionreducer/examples/counter/go.mod +++ b/pkg/sessionreducer/examples/counter/go.mod @@ -2,7 +2,7 @@ module counter go 1.20 -replace github.com/numaproj/numaflow-go => ../../../../../numaflow-go +replace github.com/numaproj/numaflow-go => ../../../.. require ( github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 diff --git a/pkg/sideinput/examples/simple-sideinput/go.mod b/pkg/sideinput/examples/simple-sideinput/go.mod index 544d8199..b2c3daa2 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 -replace github.com/numaproj/numaflow-go => ../../../../../numaflow-go +replace github.com/numaproj/numaflow-go => ../../../.. require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 diff --git a/pkg/sideinput/examples/simple-sideinput/udf/go.mod b/pkg/sideinput/examples/simple-sideinput/udf/go.mod index 51c4d002..b2e9caea 100644 --- a/pkg/sideinput/examples/simple-sideinput/udf/go.mod +++ b/pkg/sideinput/examples/simple-sideinput/udf/go.mod @@ -2,7 +2,7 @@ module even_odd go 1.20 -replace github.com/numaproj/numaflow-go => ../../../../../../numaflow-go +replace github.com/numaproj/numaflow-go => ../../../../.. require ( github.com/fsnotify/fsnotify v1.6.0 diff --git a/pkg/sinker/examples/log/go.mod b/pkg/sinker/examples/log/go.mod index af7b8d2c..a22cf0f9 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 -replace github.com/numaproj/numaflow-go => ../../../../../numaflow-go +replace github.com/numaproj/numaflow-go => ../../../.. require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 diff --git a/pkg/sourcer/examples/simple_source/go.mod b/pkg/sourcer/examples/simple_source/go.mod index 167f6b05..5eb180a0 100644 --- a/pkg/sourcer/examples/simple_source/go.mod +++ b/pkg/sourcer/examples/simple_source/go.mod @@ -2,7 +2,7 @@ module simple_source go 1.20 -replace github.com/numaproj/numaflow-go => ../../../../../numaflow-go +replace github.com/numaproj/numaflow-go => ../../../.. require ( github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 diff --git a/pkg/sourcetransformer/examples/assign_event_time/go.mod b/pkg/sourcetransformer/examples/assign_event_time/go.mod index 0bfaec40..72254972 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 -replace github.com/numaproj/numaflow-go => ../../../../../numaflow-go +replace github.com/numaproj/numaflow-go => ../../../.. require github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 diff --git a/pkg/sourcetransformer/examples/event_time_filter/go.mod b/pkg/sourcetransformer/examples/event_time_filter/go.mod index 09fdf50a..c2f33951 100644 --- a/pkg/sourcetransformer/examples/event_time_filter/go.mod +++ b/pkg/sourcetransformer/examples/event_time_filter/go.mod @@ -2,7 +2,7 @@ module event_time_filter go 1.20 -replace github.com/numaproj/numaflow-go => ../../../../../numaflow-go +replace github.com/numaproj/numaflow-go => ../../../.. require ( github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1