init

Signed-off-by: Sidhant Kohli <sidhant.kohli@gmail.com>

Author: kohlisid

pynumaflow/mapper/__init__.py

@@ -1,3 +1,4 @@
+from pynumaflow.mapper.async_multiproc_server import AsyncMapMultiprocServer
 from pynumaflow.mapper.async_server import MapAsyncServer
 from pynumaflow.mapper.multiproc_server import MapMultiprocServer
 from pynumaflow.mapper.sync_server import MapServer
@@ -13,4 +14,5 @@
     "MapServer",
     "MapAsyncServer",
     "MapMultiprocServer",
+    "AsyncMapMultiprocServer"
 ]

pynumaflow/mapper/async_multiproc_server.py

@@ -33,7 +33,7 @@
 _LOGGER = logging.getLogger(__name__)
 
 
-class AsyncMultiprocMapServer(NumaflowServer):
+class AsyncMapMultiprocServer(NumaflowServer):
     """
     A multiprocess asynchronous gRPC server for Numaflow Map UDFs.
     Spawns N worker processes, each running an asyncio-based gRPC server.