pynumaflow

View on PyPIReverse Dependencies (2)

0.7.0 pynumaflow-0.7.0-py3-none-any.whl

Wheel Details

Project: pynumaflow
Version: 0.7.0
Filename: pynumaflow-0.7.0-py3-none-any.whl
Download: [link]
Size: 104449
MD5: bb51d28d0d92c6c3964df850d592e4a4
SHA256: 67cf0d98bb4603b57413d5e527b4dfba650f6049706e148a486eae5cf84cf194
Uploaded: 2024-05-03 17:33:14 +0000

dist-info

METADATA

Metadata-Version: 2.1
Name: pynumaflow
Version: 0.7.0
Summary: Provides the interfaces of writing Python User Defined Functions and Sinks for NumaFlow.
Author: NumaFlow Developers
Maintainer: Avik Basu
Maintainer-Email: avikbasu93[at]gmail.com
Home-Page: https://github.com/numaproj/numaflow-python
Project-Url: Repository, https://github.com/numaproj/numaflow-python
License: Apache-2.0
Classifier: Intended Audience :: Developers
Classifier: License :: OSI Approved :: Apache Software License
Classifier: Programming Language :: Python :: 3
Classifier: Programming Language :: Python :: 3.9
Classifier: Programming Language :: Python :: 3.10
Classifier: Programming Language :: Python :: 3.11
Classifier: Topic :: Software Development :: Libraries
Requires-Python: >=3.9,<3.12
Requires-Dist: aiorun (<2024.0,>=2023.7)
Requires-Dist: google-api-core (<3.0.0,>=2.11.0)
Requires-Dist: google-cloud (<0.35.0,>=0.34.0)
Requires-Dist: grpcio (<2.0.0,>=1.48.1)
Requires-Dist: grpcio-tools (<2.0.0,>=1.48.1)
Requires-Dist: protobuf (<5.0,>=3.20)
Requires-Dist: psutil (<6.0.0,>=5.9.8)
Requires-Dist: uvloop (<0.20.0,>=0.19.0)
Description-Content-Type: text/markdown
[Description omitted; length: 6679 characters]

WHEEL

Wheel-Version: 1.0
Generator: poetry-core 1.9.0
Root-Is-Purelib: true
Tag: py3-none-any

RECORD

Path Digest Size
pynumaflow/__init__.py sha256=YJVzli43c3ZGvSYV_I-vFHY-2o7B-Svb92RM8WUMwJg 985
pynumaflow/_constants.py sha256=GUSpDmT7cfzTVxhfgD2ARxDV0hR5XB4WlsxPiXnM_bs 2298
pynumaflow/exceptions.py sha256=sG1naE70Mkj5n6rKeABipyznpRMgwE4_UkkO0mVbatA 332
pynumaflow/info/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
pynumaflow/info/server.py sha256=scZfmFlQQOyeyjXCS05jz0oA9UPjcyhawIF-olp7g6w 1594
pynumaflow/info/types.py sha256=BLlJL66J7fVN4akLv2Og4N3CsOnDTBty2dCg7QKfokc 1422
pynumaflow/mapper/__init__.py sha256=ImORoHu8DAKRGNQceW1VWRBsEwIc_SbWLIQG55e3jAM 404
pynumaflow/mapper/_dtypes.py sha256=MRlzvv2_Az2nApqctCIQLRYvW3ovMh2e2FpOUm7Bowo 5885
pynumaflow/mapper/async_server.py sha256=lEA0wBbRZ1GSeDNJIKKULuhXmhBx2hJm4vnXd32RWOU 3883
pynumaflow/mapper/multiproc_server.py sha256=kVIsVlPPW-fpXHi4IyXs4Upx6ZXVRtOdxVhbhGKKU7I 4308
pynumaflow/mapper/servicer/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
pynumaflow/mapper/servicer/async_servicer.py sha256=IeiJ3CSLwR3ky60Qbol31wdQZCoiy5TiN4bPVd9gkko 2806
pynumaflow/mapper/servicer/sync_servicer.py sha256=qd68ctPE4vNwbNRLZ_eJMKMcUd8CB0S3jrbAHiYSfWA 1482
pynumaflow/mapper/servicer/utils.py sha256=FzhzWRbyRJ0MsLcxcr5l8al7qs8jdRYvflhRe969oeQ 1380
pynumaflow/mapper/sync_server.py sha256=cj3pTFjjDOvhzdQCAanX1H-1Al0xyrgfmnfOcPT0qIA 3912
pynumaflow/mapstreamer/__init__.py sha256=d7V341Mtmo6P9r6XRM5XNHA-cv3s_toCkXCpCRxOd2I 308
pynumaflow/mapstreamer/_dtypes.py sha256=xdveIN9ISmAaoaM1BSt-iigotyTWhpXzceX6zebE4mA 5595
pynumaflow/mapstreamer/async_server.py sha256=eTrOZVJ-WqXZTnPE25qkAyqhc7q45f8Ajiy5GwuI3MQ 4654
pynumaflow/mapstreamer/servicer/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
pynumaflow/mapstreamer/servicer/async_servicer.py sha256=bIiRaoupWwxHknLPyvY6v7WbobFFROWefhnFr2XdcBE 2821
pynumaflow/proto/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
pynumaflow/proto/mapper/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
pynumaflow/proto/mapper/map.proto sha256=vDNedm4KNMH8n2HDk3QCvOBaog3ysQysUc-ioX3io_4 908
pynumaflow/proto/mapper/map_pb2.py sha256=zKB8gSma4zUTwb4W3VG2SCB1KLXUbezWP6gST6zA8R8 2731
pynumaflow/proto/mapper/map_pb2_grpc.py sha256=TUoIrvGG67fjB6wkno1OlfgQ4PXNXQemZsXJM4n62oo 3906
pynumaflow/proto/mapstreamer/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
pynumaflow/proto/mapstreamer/mapstream.proto sha256=0Ro6tzO2ITtZ9HOAppz5o9VU2pSloLOfI2z5YnBTMtE 983
pynumaflow/proto/mapstreamer/mapstream_pb2.py sha256=NPb3Db7FWta1SG_Bp-xeL6RO9SVaR7LTCnj31MNX_wQ 2913
pynumaflow/proto/mapstreamer/mapstream_pb2_grpc.py sha256=ZajdXI4bHAwHV7iAj0BHlqcNqz9FNhlaVOFKPLap_RI 4174
pynumaflow/proto/reducer/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
pynumaflow/proto/reducer/reduce.proto sha256=OtQiTJ0GQMFuZaYFMq9T6oClOoo8gxae_yJTnWEXRBo 1823
pynumaflow/proto/reducer/reduce_pb2.py sha256=bvbEjeYDvqXAk0yTzIzDe58KCDIgGTBglB9gyoU3rK0 4133
pynumaflow/proto/reducer/reduce_pb2_grpc.py sha256=kjw4JEUTX7rYS5OjW_E6dtpEFM2Ki2Uc1BqtIcEVyZg 4055
pynumaflow/proto/sideinput/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
pynumaflow/proto/sideinput/sideinput.proto sha256=-0T5qX9J-hYEaRyLigeLyDEueFryqTMBpEFetrSSmJQ 1482
pynumaflow/proto/sideinput/sideinput_pb2.py sha256=z620_Te-i8VYmspvLSmXT5L_Bd7K4Gl46fQz_1XKLo4 1699
pynumaflow/proto/sideinput/sideinput_pb2_grpc.py sha256=05L6DIC9HH-hQmKsvzPZBhm3HzBF4d15ILLalUotsv8 5798
pynumaflow/proto/sinker/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
pynumaflow/proto/sinker/sink.proto sha256=byi1Nub5U8ej71A8t-qHyL5QNNYll0j2zptwyiyzmh0 1318
pynumaflow/proto/sinker/sink_pb2.py sha256=I3qw56AnU5rtQmnJOZJnbc04sGa-TiFKsB-wwcn72CY 3037
pynumaflow/proto/sinker/sink_pb2_grpc.py sha256=MfPqBQ6pbRoRm4C24yE5xFU1tKz6iDKs9lK_L_jMOAE 3970
pynumaflow/proto/sourcer/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
pynumaflow/proto/sourcer/source.proto sha256=a2OVIkGqPgutm_ObAg_Iu7CHz3DzwDaPp_ZwZIEk9oU 6480
pynumaflow/proto/sourcer/source_pb2.py sha256=ZmZuT1UWPVqKhmATMXcO1R6GN6GUbeo1LzdXhQlX1_8 5075
pynumaflow/proto/sourcer/source_pb2_grpc.py sha256=2OQtLdprtODe7oZ_C-FJVIqoaGDPqf201q90dHQ-SFA 9375
pynumaflow/proto/sourcetransformer/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
pynumaflow/proto/sourcetransformer/transform.proto sha256=Q9oZij6Vm3KTVyZTJpyH6zrC7k13eD49OcBqYloODk8 1267
pynumaflow/proto/sourcetransformer/transform_pb2.py sha256=BRkg9CA3yWG_Eolhb6A_5dLket4408-9q5q5ixhidsQ 3151
pynumaflow/proto/sourcetransformer/transform_pb2_grpc.py sha256=ZDcUfQthsWNGp7N0p1nO5z4Ugs6osBBgJwiMQ-LjD2I 4534
pynumaflow/reducer/__init__.py sha256=Zxuv5hc4QKCVMpi0P-8H4ph69nRu8qzNyk4qFf0r_Zg 349
pynumaflow/reducer/_dtypes.py sha256=-y4JcwWUY129w3YHBwa08VoQSlEkh4iWqohrEa7LkLo 10780
pynumaflow/reducer/async_server.py sha256=L3ahBAUUdurj82Gp529P-69HvWNXIWKR-Z268zaHotM 6797
pynumaflow/reducer/servicer/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
pynumaflow/reducer/servicer/async_servicer.py sha256=7i3-cQKgD85MTTZJ2QaFx_myaPjXlGI-OaQkwPqAZJo 6656
pynumaflow/reducer/servicer/task_manager.py sha256=ZXpNyVKFjxrTZwxkeXOZ0ZciOal8XBPXb4P8N3QU8vk 6975
pynumaflow/reducestreamer/__init__.py sha256=jm5mY4BByfP2jGHCkHSAc4mt2DPevrjpq7lQ-I2Pgiw 397
pynumaflow/reducestreamer/_dtypes.py sha256=PUbJXwHTVoj_HRX86DdEoSh0LV8Ai1HY98zGZmS30LM 9558
pynumaflow/reducestreamer/async_server.py sha256=lOhvxEme7EbBh6Sc-lamzGFm5w5FtwnqXp6ssjNTWcE 7586
pynumaflow/reducestreamer/servicer/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
pynumaflow/reducestreamer/servicer/async_servicer.py sha256=yldER-G-Yxiz1QmoJBC-9piX9v4RBem2cZ6e9rw2u1Y 6284
pynumaflow/reducestreamer/servicer/task_manager.py sha256=-bC___rN_w4d3JXl7iq7btDUM42NqniDQefgg90pp9s 12061
pynumaflow/shared/__init__.py sha256=CAfUx0DKPrqGGaLoqWm3s1Jl3v5McUFhthTPvq4QZ4k 83
pynumaflow/shared/asynciter.py sha256=KpxMMstRbVI1St5wJu2Viy6N6cqHAuWY-2DrxTX86PU 512
pynumaflow/shared/server.py sha256=-C6ncQotTK9PMvqVdnlcUltk0btPEvl-UJaFyJ9dAqs 9111
pynumaflow/sideinput/__init__.py sha256=DepLSQXD8M_V-a2UnaM0FVevQ6dBtX8SgtH7Io6hz0Y 250
pynumaflow/sideinput/_dtypes.py sha256=c5lTanxHkieeUsK5uEN2vTVdTEdyh79MPCzeD3vRn8I 1826
pynumaflow/sideinput/server.py sha256=k0JgG5uw8auwDPdN5xvrZfzlz7-ZG-O4HnYPCX57flM 3484
pynumaflow/sideinput/servicer/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
pynumaflow/sideinput/servicer/servicer.py sha256=6CKcHtUQwIsfg7LrSSuQqHZW1-eLBGGbhQVj_AP724s 1656
pynumaflow/sinker/__init__.py sha256=FhPz5LB0a7sef1RXa_wATZJU3F4xlGf9pFjWfOZME0Q 270
pynumaflow/sinker/_dtypes.py sha256=9IgztM2enP5vYXOxejK7fK-lqSdyETR-PHYf9rp0ttQ 6886
pynumaflow/sinker/async_server.py sha256=d4eMOW0NJbfpQAOhlaS6ayMeYK9q3l3_DeEmxmTiEJI 4578
pynumaflow/sinker/server.py sha256=o3ohDzifwvUKml5BRTnqAyMjdm65F__MLNFZkwxBlUM 4266
pynumaflow/sinker/servicer/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
pynumaflow/sinker/servicer/async_servicer.py sha256=GlQwnMgEyoZKr7cUNeMvg4Y2Shs1q2BoQI9l6fp6b-I 3052
pynumaflow/sinker/servicer/sync_servicer.py sha256=iT0RtV6VnKN8d9EnNfknpzj4YXzAivLf6LKF9AUNUfE 2497
pynumaflow/sinker/servicer/utils.py sha256=Zt3yal-ujwbSEMqQtOoIcmgD6kTVZU-8nFPgzQ5kpwM 495
pynumaflow/sourcer/__init__.py sha256=owjhq84n8pWEcV5i0jF51LhKAxFJFXTQYfxCAmmlhPY 520
pynumaflow/sourcer/_dtypes.py sha256=e42JPmTrsHDLpg0kr-WBxWWWo_qIclhMs1SXevCxteY 7957
pynumaflow/sourcer/async_server.py sha256=aLZ_PXgSNWaYEa3ciB_SrmTprpSjzL2Y14E8dxKsG38 5712
pynumaflow/sourcer/server.py sha256=yEh5E0m0UarHkNy0xywIPcNDnxZ7ISYxqyFWypAJUCE 5375
pynumaflow/sourcer/servicer/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
pynumaflow/sourcer/servicer/async_servicer.py sha256=a_xMYp6lBjetwT8wG1FFsjrhFLA1EdQWTKVo5vq-IbQ 5713
pynumaflow/sourcer/servicer/sync_servicer.py sha256=d-kLAORFABgzhBA2rYMlBp3OBat3DrXjiBsOTiPbvnc 6191
pynumaflow/sourcetransformer/__init__.py sha256=8EQxGsGGkf_BrB_NbhVukp6_a8wZi3rYna5vjWiOPdI 446
pynumaflow/sourcetransformer/_dtypes.py sha256=D4joeEe2P4flnJmnz2quRDEpcf7dVxh1EyhwVWBxrQs 6048
pynumaflow/sourcetransformer/multiproc_server.py sha256=0Wzm5IHCZIjxcCvv7U8RNoo9QfQgLW79o9g5dj80hHI 5224
pynumaflow/sourcetransformer/server.py sha256=NnTernXCni3T_o4NMiYj5AQans3PJRlqG40bSqsmaLs 4845
pynumaflow/sourcetransformer/servicer/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
pynumaflow/sourcetransformer/servicer/server.py sha256=juBqYZomyJWLBbIrG6UOyW3MctTr8GLg3-77-xFwqLE 3145
pynumaflow/types.py sha256=EVSs4YlPw1JpbgR4Fot5p7YMtRt8f6DZnCNiRlvFyQ0 170
pynumaflow-0.7.0.dist-info/LICENSE sha256=xx0jnfkXJvxRnG63LTGOxlggYnIysveWIZ6H3PNdCrQ 11357
pynumaflow-0.7.0.dist-info/METADATA sha256=BFmhEKaVLaAQztMGIWQdRBbrq31o4b4d3LBYOuSuNrA 7837
pynumaflow-0.7.0.dist-info/WHEEL sha256=sP946D7jFCHeNz5Iq4fL4Lu-PrWrFsgfLXbbkciIZwg 88
pynumaflow-0.7.0.dist-info/RECORD