From 2742b562420d4b1a2b82e925740e1d6f32388e66 Mon Sep 17 00:00:00 2001 From: Sidhant Kohli Date: Wed, 17 Jan 2024 08:45:35 -0800 Subject: [PATCH] examples Signed-off-by: Sidhant Kohli --- examples/map/multiproc_map/Makefile | 2 +- examples/sideinput/simple-sideinput/udf/example.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/examples/map/multiproc_map/Makefile b/examples/map/multiproc_map/Makefile index 283e90b7..e7679224 100644 --- a/examples/map/multiproc_map/Makefile +++ b/examples/map/multiproc_map/Makefile @@ -1,6 +1,6 @@ .PHONY: image image: - docker buildx build --no-cache -t "quay.io/kohlisid/numaflow-python/refactor:v0.7.2" --platform linux/amd64,linux/arm64 . --push + docker build -t "quay.io/numaio/numaflow-python/multiproc:v0.7.0" . # Github CI runner uses platform linux/amd64. If your local environment don't, the image built by command above might not work # under the CI E2E test environment. # To build an image that supports multiple platforms(linux/amd64,linux/arm64) and push to quay.io, use the following command diff --git a/examples/sideinput/simple-sideinput/udf/example.py b/examples/sideinput/simple-sideinput/udf/example.py index e9eaa464..5f3bc8f1 100644 --- a/examples/sideinput/simple-sideinput/udf/example.py +++ b/examples/sideinput/simple-sideinput/udf/example.py @@ -24,7 +24,7 @@ def watcher(): This function is used to start the GRPC server and the watcher thread. """ daemon = Thread(target=watcher, daemon=True, name="Monitor") - grpc_server = MapServer(mapper_instance=my_handler) + grpc_server = MapServer(my_handler) thread_server = Thread(target=grpc_server.start, daemon=True, name="GRPC Server") daemon.start() thread_server.start()