We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 38e8544 commit f2c6d33Copy full SHA for f2c6d33
1 file changed
pynumaflow/sourcetransformer/servicer/_async_servicer.py
@@ -13,18 +13,6 @@
13
from pynumaflow.types import NumaflowServicerContext
14
15
16
-def _create_read_handshake_response() -> transform_pb2.SourceTransformResponse:
17
- """
18
- Create a handshake response for the SourceTransform function.
19
-
20
- Returns:
21
- SourceTransformResponse: A SourceTransformResponse object indicating a successful handshake.
22
23
- return transform_pb2.SourceTransformResponse(
24
- handshake=transform_pb2.Handshake(sot=True),
25
- )
26
27
28
class SourceTransformAsyncServicer(transform_pb2_grpc.SourceTransformServicer):
29
"""
30
This class is used to create a new grpc SourceTransform Async Servicer instance.
0 commit comments