fix: udf type in multiproc source transformer (#171)

kohlisid · web-flow · commit 225e8b0cce2c · 2024-06-08T11:19:22.000-07:00
Signed-off-by: Sidhant Kohli &lt;sidhant.kohli@gmail.com&gt;
diff --git a/pynumaflow/sourcetransformer/multiproc_server.py b/pynumaflow/sourcetransformer/multiproc_server.py
@@ -127,5 +127,5 @@ def start(self):
             process_count=self._process_count,
             server_info_file=self.server_info_file,
             server_options=self._server_options,
-            udf_type=UDFType.Map,
+            udf_type=UDFType.SourceTransformer,
         )

Original file line number	Diff line number	Diff line change
`@@ -127,5 +127,5 @@ def start(self):`
`127`	`127`	`process_count=self._process_count,`
`128`	`128`	`server_info_file=self.server_info_file,`
`129`	`129`	`server_options=self._server_options,`
`130`		`- udf_type=UDFType.Map,`
	`130`	`+ udf_type=UDFType.SourceTransformer,`
`131`	`131`	`)`