update function socket (#12)

numaproj · Sep 30, 2022 · 3559e15 · 3559e15
1 parent dd861c0
commit 3559e15
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pynumaflow/_constants.py b/pynumaflow/_constants.py
@@ -2,7 +2,7 @@
 APPLICATION_MSG_PACK = "application/msgpack"
 NUMAFLOW_UDF_CONTENT_TYPE = "NUMAFLOW_UDF_CONTENT_TYPE"
 NUMAFLOW_MESSAGE_KEY = "x-numa-message-key"
-FUNCTION_SOCK_PATH = "/var/run/numaflow/udf.sock"
+FUNCTION_SOCK_PATH = "/var/run/numaflow/function.sock"
 SINK_SOCK_PATH = "/var/run/numaflow/udsink.sock"
 # TODO: need to make sure the DATUM_KEY value is the same as
 # https://github.com/numaproj/numaflow-go/blob/main/pkg/function/configs.go#L6