File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed
packages/pynumaflow/pynumaflow/shared Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change 11import contextlib
22import io
33import multiprocessing
4+ import multiprocessing .synchronize
45import os
56import socket
67import threading
@@ -88,7 +89,7 @@ def _run_server(
8889 udf_type : str ,
8990 server_info_file : str | None = None ,
9091 server_info : ServerInfo | None = None ,
91- shutdown_event : threading .Event | multiprocessing . Event | None = None ,
92+ shutdown_event : threading .Event | None = None ,
9293) -> None :
9394 """
9495 Starts the Synchronous server instance on the given UNIX socket
@@ -149,7 +150,7 @@ def start_multiproc_server(
149150 server_info : ServerInfo | None = None ,
150151 server_options = None ,
151152 udf_type : str = UDFType .Map ,
152- shutdown_event : multiprocessing .Event | None = None ,
153+ shutdown_event : multiprocessing .synchronize . Event | None = None ,
153154):
154155 """
155156 Start N grpc servers in different processes where N = The number of CPUs or the
You can’t perform that action at this time.
0 commit comments