examples

Signed-off-by: Sidhant Kohli <[email protected]>
numaproj · Jan 17, 2024 · 2742b56 · 2742b56
1 parent dffdc5f
commit 2742b56
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git 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
@@ -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()