clean

kohlisid · kohlisid · commit 77953faa949f · 2025-06-18T16:02:56.000-07:00
Signed-off-by: Sidhant Kohli &lt;sidhant.kohli@gmail.com&gt;
diff --git a/examples/sourcetransform/async_event_time_filter/example.py b/examples/sourcetransform/async_event_time_filter/example.py
@@ -2,7 +2,7 @@
 import logging
 
 from pynumaflow.sourcetransformer import Messages, Message, Datum
-from pynumaflow.sourcetransformer.async_server import SourceTransformAsyncServer
+from pynumaflow.sourcetransformer import SourceTransformAsyncServer
 
 """
 This is a simple User Defined Function example which receives a message, applies the following
diff --git a/pynumaflow/sourcetransformer/__init__.py b/pynumaflow/sourcetransformer/__init__.py
@@ -7,6 +7,7 @@
 )
 from pynumaflow.sourcetransformer.multiproc_server import SourceTransformMultiProcServer
 from pynumaflow.sourcetransformer.server import SourceTransformServer
+from pynumaflow.sourcetransformer.async_server import SourceTransformAsyncServer
 
 __all__ = [
     "Message",
@@ -16,4 +17,5 @@
     "SourceTransformServer",
     "SourceTransformer",
     "SourceTransformMultiProcServer",
+    "SourceTransformAsyncServer",
 ]

Original file line number	Diff line number	Diff line change
`@@ -7,6 +7,7 @@`
`7`	`7`	`)`
`8`	`8`	`from pynumaflow.sourcetransformer.multiproc_server import SourceTransformMultiProcServer`
`9`	`9`	`from pynumaflow.sourcetransformer.server import SourceTransformServer`
	`10`	`+from pynumaflow.sourcetransformer.async_server import SourceTransformAsyncServer`
`10`	`11`
`11`	`12`	`__all__ = [`
`12`	`13`	`"Message",`
`@@ -16,4 +17,5 @@`
`16`	`17`	`"SourceTransformServer",`
`17`	`18`	`"SourceTransformer",`
`18`	`19`	`"SourceTransformMultiProcServer",`
	`20`	`+ "SourceTransformAsyncServer",`
`19`	`21`	`]`