pynumaflow

View on PyPIReverse Dependencies (1)

0.9.0 pynumaflow-0.9.0-py3-none-any.whl

Wheel Details

Project: pynumaflow
Version: 0.9.0
Filename: pynumaflow-0.9.0-py3-none-any.whl
Download: [link]
Size: 120658
MD5: 6bc770d8fe353b8cc74faad2d93ff18a
SHA256: 37c1d558b0b62dd12eea3a03e8353fe8a4259e1af13dfcfbfac9310c61400b63
Uploaded: 2024-11-08 22:47:34 +0000

dist-info

METADATA

Metadata-Version: 2.1
Name: pynumaflow
Version: 0.9.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: Programming Language :: Python :: 3.12
Classifier: Topic :: Software Development :: Libraries
Requires-Python: >=3.9,<3.13
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 (<7.0.0,>=6.0.0)
Requires-Dist: uvloop (<0.20.0,>=0.19.0)
Description-Content-Type: text/markdown
[Description omitted; length: 6881 characters]

WHEEL

Wheel-Version: 1.0
Generator: poetry-core 1.9.1
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=bx34fmGwUEOvEjBe1gR5LDnojhH63bARQI5YFZpXQz8 2379
pynumaflow/batchmapper/__init__.py sha256=JsnXbm134Rr1cVrv_DTF0dOFHLs-XhuKs82ciugiAiA 379
pynumaflow/batchmapper/_dtypes.py sha256=9QRvErdd6A0OdBox1FBtJRPrvoPelTf8r0wg9jPewbE 5866
pynumaflow/batchmapper/async_server.py sha256=ARb24DKCKfRPDpWpTUbohKZC606H0o-4Uuq4w8JbTxE 4675
pynumaflow/batchmapper/servicer/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
pynumaflow/batchmapper/servicer/async_servicer.py sha256=dtKhyWqcu7HLCvCzJ_844vFRKRB4RA-pUVZkBj7wH9g 5206
pynumaflow/exceptions.py sha256=sG1naE70Mkj5n6rKeABipyznpRMgwE4_UkkO0mVbatA 332
pynumaflow/info/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
pynumaflow/info/server.py sha256=2GHtygLe4ocKPrrBMvvxBHvdtCZJdc3_xldP4GFdYJk 1184
pynumaflow/info/types.py sha256=7ynG3-bY0YM2XJmXRMAYLelwoRQdgU6lRL2a-Eu2ylo 3777
pynumaflow/mapper/__init__.py sha256=ImORoHu8DAKRGNQceW1VWRBsEwIc_SbWLIQG55e3jAM 404
pynumaflow/mapper/_dtypes.py sha256=-uiGLdVYJaJz6LqgmAaxjRcIjbD0LXl8_y3WPOqZDxo 5969
pynumaflow/mapper/_servicer/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
pynumaflow/mapper/_servicer/_async_servicer.py sha256=Nnea5nps-TwnUP-O1YNp8N59Rn7M3bwVdV63lL5SeU4 5184
pynumaflow/mapper/_servicer/_sync_servicer.py sha256=O9_oONcnJv8S_mMvseW28CMp-ivAVxGhCoP_xFpPy1E 5463
pynumaflow/mapper/async_server.py sha256=INZfPbyCihlFOuAZQjI1hUiho3V2Iwdxc5RyChpNwhM 4434
pynumaflow/mapper/multiproc_server.py sha256=eB1AcbPk-VBy2rmMYgMANWMCcjL6hpTPJqdcxFf_RVc 4959
pynumaflow/mapper/sync_server.py sha256=wf6fZuzo8KTx_TKH6LLZ6Qg61j7LPi3Slt7T6PM_Au0 4377
pynumaflow/mapstreamer/__init__.py sha256=d7V341Mtmo6P9r6XRM5XNHA-cv3s_toCkXCpCRxOd2I 308
pynumaflow/mapstreamer/_dtypes.py sha256=TMq1g8TqjHqnIVaobSs8bLk6N1MDG-jGB8nVyIPlaVw 5691
pynumaflow/mapstreamer/async_server.py sha256=c3LIDw6TG5hurVE7pw4fi5AxnvpIsCZhcCcAZt6fLlM 5250
pynumaflow/mapstreamer/servicer/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
pynumaflow/mapstreamer/servicer/async_servicer.py sha256=zVctzLAFqs0SgjE4yLcm0QPxnT0KZ9gn5NnLwqVU_4U 3457
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=yOfpV5bJtflvtR2CjWD9PoHuSIUlwLLefFZClMaJ_kk 1684
pynumaflow/proto/mapper/map_pb2.py sha256=2qkJJtKjuZcle0Le8n06yYk2u17HVRM0nf7moJDAdd0 3989
pynumaflow/proto/mapper/map_pb2.pyi sha256=J6pAU728q82eol3tSGeu0flApa4UqZdXZAYumWtfQBw 4159
pynumaflow/proto/mapper/map_pb2_grpc.py sha256=3CuAKmlqFhOBvjjQ54YDd2lu6u3r5EZc7_sVf5YpGpo 3939
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.pyi sha256=heAj5m4kLnLbWV8ZidkAX3WJGb7WX1NGFkwF3gp_9-U 4959
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.pyi sha256=KwGWh8-aWY85PKgyoHv1Cgke7jxWqmrsamwFYLFjL7U 739
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=xjVYqPTMSBiOhYJoCJhzlkGSYlk_ndRsRdpCXM_Wu4k 2057
pynumaflow/proto/sinker/sink_pb2.py sha256=9YT_n2bXbsEyMV2wgiWmtTb-KSQt9Jrdr4IJg9J7Prc 4010
pynumaflow/proto/sinker/sink_pb2.pyi sha256=2ffybkdl5jgmHi0i76Eq8aEvN00VxzTOxsCLW8DnBSY 4312
pynumaflow/proto/sinker/sink_pb2_grpc.py sha256=Y6e2QBeazEnKAU_izTpkOTBLAID6dOccWMwroQWJL2E 3973
pynumaflow/proto/sourcer/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
pynumaflow/proto/sourcer/source.proto sha256=UyVctHQvMyEhUVHaf0G4tTmC5k8JEnKY1AGsohDPSjI 7491
pynumaflow/proto/sourcer/source_pb2.py sha256=HF4AkVgjgI36_tknXohxNamW7FZvS-cnA1aBoZ80318 6616
pynumaflow/proto/sourcer/source_pb2.pyi sha256=pk7-8PMyUFLUAMbPAtjXHvZ3L3HNEHDY2m3oCGhTqk0 7424
pynumaflow/proto/sourcer/source_pb2_grpc.py sha256=scVFJUMLdkUiLQ-rqPuoGy5D-p6zaiHeZM9Yt_MCIDU 9740
pynumaflow/proto/sourcetransformer/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
pynumaflow/proto/sourcetransformer/transform.proto sha256=-cRoB16XKmNabyRTPikEpEcjxWy1Sr30pkDvdkPVtS0 1868
pynumaflow/proto/sourcetransformer/transform_pb2.py sha256=Ng0n3K9yi92pNEzFLT9k7PAiKPpjgNz4jMCbQ7B-OMA 3915
pynumaflow/proto/sourcetransformer/transform_pb2.pyi sha256=JPigYQgqxJD9ZJVpeqSknpmsl6ltYaBNgzepHZu1Q40 3957
pynumaflow/proto/sourcetransformer/transform_pb2_grpc.py sha256=tXVL8AmFQeeiZSmgDE_ecyRtL1u2VxmrA_X95WpvR5M 4567
pynumaflow/reducer/__init__.py sha256=Zxuv5hc4QKCVMpi0P-8H4ph69nRu8qzNyk4qFf0r_Zg 349
pynumaflow/reducer/_dtypes.py sha256=-y4JcwWUY129w3YHBwa08VoQSlEkh4iWqohrEa7LkLo 10780
pynumaflow/reducer/async_server.py sha256=NJtfDIvsZJDEG4CugAXwAx4s6YydG4sGxeh57ThvyV0 7400
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=keO8dPm7h26GcKXPWZSDsb9zDBySDYzLlQzAtEOQhvE 8127
pynumaflow/reducestreamer/servicer/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
pynumaflow/reducestreamer/servicer/async_servicer.py sha256=KM0tPLsb5H9wRwN5z2HVAz-qVcoaZE50T9E7YOpib1s 4982
pynumaflow/reducestreamer/servicer/task_manager.py sha256=-bC___rN_w4d3JXl7iq7btDUM42NqniDQefgg90pp9s 12061
pynumaflow/shared/__init__.py sha256=CAfUx0DKPrqGGaLoqWm3s1Jl3v5McUFhthTPvq4QZ4k 83
pynumaflow/shared/asynciter.py sha256=sPHWOLTuiCCuqp9D_E1mH_OO6VKTLDn-rUoJG3oKOxY 532
pynumaflow/shared/server.py sha256=mTpUWG1xB2Ox8iLOZO0gu8NOifY_nWbHn-dHR8z-bsE 9612
pynumaflow/shared/synciter.py sha256=fZDFij070xGh2RveGvAhP4yIF84989QIJpGAWoZ0qbE 494
pynumaflow/shared/thread_with_return.py sha256=RRON2g1ltOLj-6pZ6kn5RSI8IAQam8H8Xax44HCS4Kg 1979
pynumaflow/sideinput/__init__.py sha256=DepLSQXD8M_V-a2UnaM0FVevQ6dBtX8SgtH7Io6hz0Y 250
pynumaflow/sideinput/_dtypes.py sha256=c5lTanxHkieeUsK5uEN2vTVdTEdyh79MPCzeD3vRn8I 1826
pynumaflow/sideinput/server.py sha256=qrePfkz4Fv5CKlxgN-vn7Cv5Os_IA_LHcvOiIJJCRbE 3766
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=w0dqghLf5FnUelIdMuuoCcXI95Ctr4DhqPt3Cnvd7l0 271
pynumaflow/sinker/_dtypes.py sha256=BK0yChZ8iTKQA_ZzslYgwe7AOVfVMj7zKBBKKm8Raa8 6886
pynumaflow/sinker/async_server.py sha256=bkm7Hzwyz7W7nQGXA02zkO2xXATQ0h2D_3gQHmR3prY 4999
pynumaflow/sinker/server.py sha256=4wXo_kYsknl6ZFkIJRSmxVxnZrZA9ai3vjeK4_Xutgc 4552
pynumaflow/sinker/servicer/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
pynumaflow/sinker/servicer/async_servicer.py sha256=G310DEM6PS2ejHhh0-zVB2Bb0CwO5GawBR7kL3QQ2wg 4777
pynumaflow/sinker/servicer/sync_servicer.py sha256=iAiMZZTx1S25ra9boMKpLjjDXryfWyng_T-DW75NyBo 4385
pynumaflow/sinker/servicer/utils.py sha256=idOchy1u_7RbkB1quBzWYs1tlrK4ltEGyxyGoPFiCGc 2289
pynumaflow/sourcer/__init__.py sha256=43wqFgfXsnG5MIv3ERAXvYf6NbmjPTN5hpQHT454UK8 449
pynumaflow/sourcer/_dtypes.py sha256=NgeJ9kz7B5KnRO5y88sti-wKACBRPejI26sbwChcVn0 8043
pynumaflow/sourcer/async_server.py sha256=WvAaJR2n9KO_LDS9ExVzL09HRacE3lhI9iU1hFCaSoA 6158
pynumaflow/sourcer/servicer/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
pynumaflow/sourcer/servicer/async_servicer.py sha256=K4OFLpXYUaB4GB56kvOk7WyzS6sBztK_AZ1AmqCvH70 8855
pynumaflow/sourcetransformer/__init__.py sha256=8EQxGsGGkf_BrB_NbhVukp6_a8wZi3rYna5vjWiOPdI 446
pynumaflow/sourcetransformer/_dtypes.py sha256=D4joeEe2P4flnJmnz2quRDEpcf7dVxh1EyhwVWBxrQs 6048
pynumaflow/sourcetransformer/multiproc_server.py sha256=Pjx_68-UWf4dVv517znM8xzYej9aUmg1Q0K5BfcI5YE 5898
pynumaflow/sourcetransformer/server.py sha256=CW8thLwD8B8KQneeNXHAjmSQW9g8HcZkUcdjRn1xP5Y 5157
pynumaflow/sourcetransformer/servicer/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
pynumaflow/sourcetransformer/servicer/_servicer.py sha256=YfcOsDd8jvtugBxaVd0G6ETfZrD-QTT3jlwEY6emi78 6446
pynumaflow/types.py sha256=EVSs4YlPw1JpbgR4Fot5p7YMtRt8f6DZnCNiRlvFyQ0 170
pynumaflow-0.9.0.dist-info/LICENSE sha256=xx0jnfkXJvxRnG63LTGOxlggYnIysveWIZ6H3PNdCrQ 11357
pynumaflow-0.9.0.dist-info/METADATA sha256=M2wjfDEqV5Xp49LXTZhjVISHWbL5aLjyge-FE_OQpcQ 8090
pynumaflow-0.9.0.dist-info/WHEEL sha256=Nq82e9rUAnEjt98J6MlVmMCZb-t9cYE2Ir1kpBmnWfs 88
pynumaflow-0.9.0.dist-info/RECORD