style: format code with black

Signed-off-by: sapkota-aayush <aayushsapkota1030@gmail.com>

Author: sapkota-aayush

examples/map/even_odd/example.py

@@ -21,7 +21,6 @@ def my_handler(keys: list[str], datum: Datum) -> Messages:
     return messages
 
 
-
 if __name__ == "__main__":
     """
     This example shows how to create a simple map function that takes in a

pynumaflow/proto/mapper/map_pb2.py

@@ -26,6 +26,7 @@ class MapRequest(_message.Message):
             key: str
             value: str
             def __init__(self, key: _Optional[str] = ..., value: _Optional[str] = ...) -> None: ...
+
         KEYS_FIELD_NUMBER: _ClassVar[int]
         VALUE_FIELD_NUMBER: _ClassVar[int]
         EVENT_TIME_FIELD_NUMBER: _ClassVar[int]
@@ -44,6 +45,7 @@ class MapRequest(_message.Message):
             watermark: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ...,
             headers: _Optional[_Mapping[str, str]] = ...,
         ) -> None: ...
+
     REQUEST_FIELD_NUMBER: _ClassVar[int]
     ID_FIELD_NUMBER: _ClassVar[int]
     HANDSHAKE_FIELD_NUMBER: _ClassVar[int]
@@ -89,6 +91,7 @@ class MapResponse(_message.Message):
             value: _Optional[bytes] = ...,
             tags: _Optional[_Iterable[str]] = ...,
         ) -> None: ...
+
     RESULTS_FIELD_NUMBER: _ClassVar[int]
     ID_FIELD_NUMBER: _ClassVar[int]
     HANDSHAKE_FIELD_NUMBER: _ClassVar[int]

pynumaflow/proto/mapper/map_pb2.pyi

@@ -25,6 +25,7 @@ class ReduceRequest(_message.Message):
             OPEN: _ClassVar[ReduceRequest.WindowOperation.Event]
             CLOSE: _ClassVar[ReduceRequest.WindowOperation.Event]
             APPEND: _ClassVar[ReduceRequest.WindowOperation.Event]
+
         OPEN: ReduceRequest.WindowOperation.Event
         CLOSE: ReduceRequest.WindowOperation.Event
         APPEND: ReduceRequest.WindowOperation.Event
@@ -48,6 +49,7 @@ class ReduceRequest(_message.Message):
             key: str
             value: str
             def __init__(self, key: _Optional[str] = ..., value: _Optional[str] = ...) -> None: ...
+
         KEYS_FIELD_NUMBER: _ClassVar[int]
         VALUE_FIELD_NUMBER: _ClassVar[int]
         EVENT_TIME_FIELD_NUMBER: _ClassVar[int]
@@ -66,6 +68,7 @@ class ReduceRequest(_message.Message):
             watermark: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ...,
             headers: _Optional[_Mapping[str, str]] = ...,
         ) -> None: ...
+
     PAYLOAD_FIELD_NUMBER: _ClassVar[int]
     OPERATION_FIELD_NUMBER: _ClassVar[int]
     payload: ReduceRequest.Payload
@@ -108,6 +111,7 @@ class ReduceResponse(_message.Message):
             value: _Optional[bytes] = ...,
             tags: _Optional[_Iterable[str]] = ...,
         ) -> None: ...
+
     RESULT_FIELD_NUMBER: _ClassVar[int]
     WINDOW_FIELD_NUMBER: _ClassVar[int]
     EOF_FIELD_NUMBER: _ClassVar[int]

pynumaflow/proto/reducer/reduce_pb2.pyi

@@ -37,6 +37,7 @@ class SinkRequest(_message.Message):
             key: str
             value: str
             def __init__(self, key: _Optional[str] = ..., value: _Optional[str] = ...) -> None: ...
+
         KEYS_FIELD_NUMBER: _ClassVar[int]
         VALUE_FIELD_NUMBER: _ClassVar[int]
         EVENT_TIME_FIELD_NUMBER: _ClassVar[int]
@@ -58,6 +59,7 @@ class SinkRequest(_message.Message):
             id: _Optional[str] = ...,
             headers: _Optional[_Mapping[str, str]] = ...,
         ) -> None: ...
+
     REQUEST_FIELD_NUMBER: _ClassVar[int]
     STATUS_FIELD_NUMBER: _ClassVar[int]
     HANDSHAKE_FIELD_NUMBER: _ClassVar[int]
@@ -106,6 +108,7 @@ class SinkResponse(_message.Message):
             status: _Optional[_Union[Status, str]] = ...,
             err_msg: _Optional[str] = ...,
         ) -> None: ...
+
     RESULTS_FIELD_NUMBER: _ClassVar[int]
     HANDSHAKE_FIELD_NUMBER: _ClassVar[int]
     STATUS_FIELD_NUMBER: _ClassVar[int]

pynumaflow/proto/sinker/sink_pb2.pyi

@@ -32,6 +32,7 @@ class ReadRequest(_message.Message):
         def __init__(
             self, num_records: _Optional[int] = ..., timeout_in_ms: _Optional[int] = ...
         ) -> None: ...
+
     REQUEST_FIELD_NUMBER: _ClassVar[int]
     HANDSHAKE_FIELD_NUMBER: _ClassVar[int]
     request: ReadRequest.Request
@@ -55,6 +56,7 @@ class ReadResponse(_message.Message):
             key: str
             value: str
             def __init__(self, key: _Optional[str] = ..., value: _Optional[str] = ...) -> None: ...
+
         PAYLOAD_FIELD_NUMBER: _ClassVar[int]
         OFFSET_FIELD_NUMBER: _ClassVar[int]
         EVENT_TIME_FIELD_NUMBER: _ClassVar[int]
@@ -81,13 +83,15 @@ class ReadResponse(_message.Message):
             __slots__ = ()
             SUCCESS: _ClassVar[ReadResponse.Status.Code]
             FAILURE: _ClassVar[ReadResponse.Status.Code]
+
         SUCCESS: ReadResponse.Status.Code
         FAILURE: ReadResponse.Status.Code
 
         class Error(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
             __slots__ = ()
             UNACKED: _ClassVar[ReadResponse.Status.Error]
             OTHER: _ClassVar[ReadResponse.Status.Error]
+
         UNACKED: ReadResponse.Status.Error
         OTHER: ReadResponse.Status.Error
         EOT_FIELD_NUMBER: _ClassVar[int]
@@ -105,6 +109,7 @@ class ReadResponse(_message.Message):
             error: _Optional[_Union[ReadResponse.Status.Error, str]] = ...,
             msg: _Optional[str] = ...,
         ) -> None: ...
+
     RESULT_FIELD_NUMBER: _ClassVar[int]
     STATUS_FIELD_NUMBER: _ClassVar[int]
     HANDSHAKE_FIELD_NUMBER: _ClassVar[int]
@@ -128,6 +133,7 @@ class AckRequest(_message.Message):
         def __init__(
             self, offsets: _Optional[_Iterable[_Union[Offset, _Mapping]]] = ...
         ) -> None: ...
+
     REQUEST_FIELD_NUMBER: _ClassVar[int]
     HANDSHAKE_FIELD_NUMBER: _ClassVar[int]
     request: AckRequest.Request
@@ -148,6 +154,7 @@ class AckResponse(_message.Message):
         def __init__(
             self, success: _Optional[_Union[_empty_pb2.Empty, _Mapping]] = ...
         ) -> None: ...
+
     RESULT_FIELD_NUMBER: _ClassVar[int]
     HANDSHAKE_FIELD_NUMBER: _ClassVar[int]
     result: AckResponse.Result
@@ -172,6 +179,7 @@ class PendingResponse(_message.Message):
         COUNT_FIELD_NUMBER: _ClassVar[int]
         count: int
         def __init__(self, count: _Optional[int] = ...) -> None: ...
+
     RESULT_FIELD_NUMBER: _ClassVar[int]
     result: PendingResponse.Result
     def __init__(
@@ -186,6 +194,7 @@ class PartitionsResponse(_message.Message):
         PARTITIONS_FIELD_NUMBER: _ClassVar[int]
         partitions: _containers.RepeatedScalarFieldContainer[int]
         def __init__(self, partitions: _Optional[_Iterable[int]] = ...) -> None: ...
+
     RESULT_FIELD_NUMBER: _ClassVar[int]
     result: PartitionsResponse.Result
     def __init__(

pynumaflow/proto/sourcer/source_pb2.pyi

@@ -32,6 +32,7 @@ class SourceTransformRequest(_message.Message):
             key: str
             value: str
             def __init__(self, key: _Optional[str] = ..., value: _Optional[str] = ...) -> None: ...
+
         KEYS_FIELD_NUMBER: _ClassVar[int]
         VALUE_FIELD_NUMBER: _ClassVar[int]
         EVENT_TIME_FIELD_NUMBER: _ClassVar[int]
@@ -53,6 +54,7 @@ class SourceTransformRequest(_message.Message):
             headers: _Optional[_Mapping[str, str]] = ...,
             id: _Optional[str] = ...,
         ) -> None: ...
+
     REQUEST_FIELD_NUMBER: _ClassVar[int]
     HANDSHAKE_FIELD_NUMBER: _ClassVar[int]
     request: SourceTransformRequest.Request
@@ -83,6 +85,7 @@ class SourceTransformResponse(_message.Message):
             event_time: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ...,
             tags: _Optional[_Iterable[str]] = ...,
         ) -> None: ...
+
     RESULTS_FIELD_NUMBER: _ClassVar[int]
     ID_FIELD_NUMBER: _ClassVar[int]
     HANDSHAKE_FIELD_NUMBER: _ClassVar[int]