Wheelodex » Projects » funnel-rocket

funnel-rocket

View on PyPI — Reverse Dependencies (0)

0.5.3 funnel_rocket-0.5.3-py3-none-any.whl

Wheel Details

Project: funnel-rocket
Version: 0.5.3
Filename: funnel_rocket-0.5.3-py3-none-any.whl
Download: [link]
Size: 193798
MD5: 73c4a084d2fc9f914bc3e93693580cb7
SHA256: 068b15eabf51780172c1106fb92f260ca844d8a78ffcb0c86e0810a8b689da47
Uploaded: 2021-05-12 11:53:33 +0000

dist-info

METADATA · WHEEL · RECORD · top_level.txt

METADATA

Metadata-Version: 2.1
Name: funnel-rocket
Version: 0.5.3
Summary: Cloud native distributed funnel queries
Author: Elad Rosenheim, Avshalom Manevich
Author-Email: elad[at]dynamicyield.com
Home-Page: https://github.com/DynamicYieldProjects/funnel-rocket-oss
Classifier: Programming Language :: Python :: 3.8
Classifier: Programming Language :: Python :: 3.9
Classifier: License :: OSI Approved :: Apache Software License
Classifier: Operating System :: OS Independent
Requires-Python: >=3.8
Requires-Dist: pyarrow (>=2.0.0)
Requires-Dist: pandas (>=1.2.0)
Requires-Dist: boto3 (>=1.16.0)
Requires-Dist: redis (>=3.5.0)
Requires-Dist: tabulate (>=0.8.0)
Requires-Dist: prometheus-client (>=0.9.0)
Requires-Dist: flask (>=1.1.0)
Requires-Dist: jsonschema (>=3.2.0)
Requires-Dist: dataclasses-json (>=0.5.2)
Requires-Dist: inflection (>=0.5.0)
Requires-Dist: parsimonious (>=0.8.0)
Requires-Dist: gunicorn (>=20.0.0)
Description-Content-Type: text/markdown
[Description omitted; length: 15917 characters]

WHEEL

Wheel-Version: 1.0
Generator: bdist_wheel (0.36.2)
Root-Is-Purelib: true
Tag: py3-none-any

RECORD

Path Digest Size
dataprep_example/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
dataprep_example/ingest_retailrocket_dataset.py sha256=9fOdvaX12Y8QxIq6e3HTk4TBdvGpufrEhMXbxN1xvIg 4906
dataprep_example/repartition.py sha256=OC1gQEK6qJUO1-oqNBQ8fg1H3sN3kq4FQa1o-fsp1pg 11162
frocket/__init__.py sha256=E9ra7p9oLUe_-Rma1btARrQHSXBe4ywLo5aY6qAfhF4 604
frocket/apiserver.py sha256=2YnEgFuD6iCJCoBggOhat5cNgMaN1M1wVz_wgw5nOKE 9904
frocket/cli.py sha256=3TKpwlRLDGrajNcLlglgx7xiEKlwZxE1ry8KvNJZReA 6944
frocket/cli_commands.py sha256=6nJYChi4AN3p0PpW7lhI8KGV6AkSl-PHEX5eRtYKUM0 5430
frocket/common/__init__.py sha256=E9ra7p9oLUe_-Rma1btARrQHSXBe4ywLo5aY6qAfhF4 604
frocket/common/config.py sha256=HgDwrKTQd1FQKNnTz9pQsAvd4Z_qMShcPnDbbWZGyMM 10086
frocket/common/dataset.py sha256=Kw9K80HYMG748megxXsXXlpE4C1eqcN2CrHkBryk0U4 7682
frocket/common/metrics.py sha256=5IIBOTKOJQ6RfN3YvWS3Djr67stjFYBrE3eZX4zB4kM 14937
frocket/common/serializable.py sha256=r2-aV_EOCBo24-blIOovMNNPoYGGZW7p0611zoZZhQs 11116
frocket/common/helpers/__init__.py sha256=E9ra7p9oLUe_-Rma1btARrQHSXBe4ywLo5aY6qAfhF4 604
frocket/common/helpers/pandas.py sha256=aLDC5zVWPQ5MsGr67HNlLG6bvuIR2QH58O5dBV-AGvs 2975
frocket/common/helpers/storage.py sha256=rVX1-q3sRj8YGsYCrKkZgTayNkV0ahseqSmkpEcVM_Q 7351
frocket/common/helpers/utils.py sha256=DmLrO5PI7c9Hzp_cNKMfwL19avBcS8jwVi4o-vevoIU 2811
frocket/common/tasks/__init__.py sha256=E9ra7p9oLUe_-Rma1btARrQHSXBe4ywLo5aY6qAfhF4 604
frocket/common/tasks/async_tracker.py sha256=1TheSsVpAlaZ6_Wi6y5HHFNOFrLrk5x6n0omYfMWm8U 7750
frocket/common/tasks/base.py sha256=ZdPImOtsMj7osEUkFVZOq1fmMQ2A7Lv22lrb8tHm8wQ 8317
frocket/common/tasks/query.py sha256=dqK3blRSCRUQ-nSF4fxM9w5yGHV8fnPA03KCw1A4RW0 5549
frocket/common/tasks/registration.py sha256=ApikE9sMkAtzmew3Jjj18UbyTyBU5gZCX2vDVE8ZxG0 2905
frocket/common/validation/__init__.py sha256=E9ra7p9oLUe_-Rma1btARrQHSXBe4ywLo5aY6qAfhF4 604
frocket/common/validation/consts.py sha256=pETI_1Ili9DQojybZbs7xNLH0oVFCIIrzJfAgOjKRio 3319
frocket/common/validation/error.py sha256=NufLGrgIk5bLEsqLxBiGn1HgNADyYS2MImoZwdWjGkI 1887
frocket/common/validation/path_visitor.py sha256=IHLRLvFB8V2z8uJEpVG-IjWoFV2wNDJHB5F5b-k_CyY 4136
frocket/common/validation/query_validator.py sha256=5SuJpbi8yfTdZifsPT1IxskkuafqsqLkcyq_9SGpKx8 18490
frocket/common/validation/relation_parser.py sha256=ITsKUkzHAiWWPvDP2IWIgfsBkIvveEO6MgGBbg_8MHI 7549
frocket/common/validation/result.py sha256=SQecmQ8CcnkPlBuBb-XHHxVPco9H_XXe3VnyL6W2wiA 1922
frocket/common/validation/visitor_functions.py sha256=XQISiCWQqZmNH8eyXoAHlv2qpqQl9K1_dbIfFAQwzD8 6843
frocket/datastore/__init__.py sha256=E9ra7p9oLUe_-Rma1btARrQHSXBe4ywLo5aY6qAfhF4 604
frocket/datastore/blobstore.py sha256=dS0_x2XkwKzSeXA-UC_2AHkXApnoEvAwGEPkwqBqUCo 1378
frocket/datastore/datastore.py sha256=3XWTalmuU5gmK7nqImNvLWIUq3l3r3r7d1eZRAjjodM 4232
frocket/datastore/redis_store.py sha256=qmHNda_cPgLPMufFzQM20U5f9WH327D3ovFQKPDIl_w 12194
frocket/datastore/registered_datastores.py sha256=2ll5nRDyCWehMZskWZvRKl3CNCFPnhfe_q6_l2X5_3w 1589
frocket/engine/__init__.py sha256=E9ra7p9oLUe_-Rma1btARrQHSXBe4ywLo5aY6qAfhF4 604
frocket/engine/query_engine.py sha256=KYmH-wn9T9j1v7DiViJknJ7eHQuhC9_INFxuhAbr7Z4 16176
frocket/engine/relation_to_pandas.py sha256=v0SptDWDkHIEnfjm7GOqY9cdkfm6MH1TmeDViVHuabc 2101
frocket/invoker/__init__.py sha256=E9ra7p9oLUe_-Rma1btARrQHSXBe4ywLo5aY6qAfhF4 604
frocket/invoker/base_invoker.py sha256=Rp5nrHtjHhCeCCr0BN6MMIoHuoLTwm0cRz-Lab4R2Tc 11963
frocket/invoker/invoker_api.py sha256=Tc7jXH8wqUutNBc3Ua7zOkknI7NEZaYL322JLRw4PV8 7600
frocket/invoker/metrics_frame.py sha256=12Au13sszlgTOHaOSKhq3PwkJsuPV0qgRz4i7g5E_xg 3863
frocket/invoker/prom_adapter.py sha256=tjBesKItYkSbaOk3ZIqd5czjaEejRNJwLwSv_kbf5WU 3207
frocket/invoker/stats_builder.py sha256=xP5sSMmImwaeSro2uenie4SQKXyl00o3_WZEQr9CkNc 8246
frocket/invoker/impl/__init__.py sha256=E9ra7p9oLUe_-Rma1btARrQHSXBe4ywLo5aY6qAfhF4 604
frocket/invoker/impl/async_invoker.py sha256=MLwl_0Kh2ivs3XN4ZARxQ0GSkloy7qfXND5oEOauEDc 8804
frocket/invoker/impl/aws_lambda_invoker.py sha256=XxM8u7opWnnnkPebmo3U86EeKq5ZHfi-w1jY5wSrwzE 5985
frocket/invoker/impl/registered_invokers.py sha256=53AfzdHlOK3kQESkswVLfL4cCwSqGS7_aES7u8UK-Rw 1489
frocket/invoker/impl/work_queue_invoker.py sha256=lnBvcF1sMtWeQDJjaBHV6e3P-Ih-ktpocUbY0yTI31E 868
frocket/invoker/jobs/__init__.py sha256=E9ra7p9oLUe_-Rma1btARrQHSXBe4ywLo5aY6qAfhF4 604
frocket/invoker/jobs/job.py sha256=OmTWlq-nInH3q2E6W9GB4bjO4YiGINcw1aabptNz9PI 3778
frocket/invoker/jobs/query_job.py sha256=LFEKNlexniVwH686e9tkWlZtWQSJvFiQlpw6uKke6nc 4865
frocket/invoker/jobs/registration_job.py sha256=gJ7LCiC1ZiyPvenVr-RdYJ6WHRkijrleM6T1u9vC86Y 14029
frocket/resources/query_schema.json sha256=vdPwKo3FtVscvmYV2UVuXbqUXHdAfqyh43jdKmL4Vas 12379
frocket/worker/__init__.py sha256=E9ra7p9oLUe_-Rma1btARrQHSXBe4ywLo5aY6qAfhF4 604
frocket/worker/impl/__init__.py sha256=E9ra7p9oLUe_-Rma1btARrQHSXBe4ywLo5aY6qAfhF4 604
frocket/worker/impl/aws_lambda_metrics.py sha256=rulxHqLTJpphKaPTmztcPpxDTjG3E7viZgwy6iN_Z2o 4156
frocket/worker/impl/aws_lambda_worker.py sha256=J5lQ2b5wp1GiS-EmLNuVCcC6MJybErMkaFSEoWhp6gw 3618
frocket/worker/impl/generic_env_metrics.py sha256=axQK8Q5bTpfCeh68OWoKrwznEfeqANaQJeDkiSyguWA 1821
frocket/worker/impl/queue_worker.py sha256=VKMDqCcBLHJGv0GDyoaIMAyiIU4-ozGQdEGleHNWr7U 2847
frocket/worker/runners/__init__.py sha256=E9ra7p9oLUe_-Rma1btARrQHSXBe4ywLo5aY6qAfhF4 604
frocket/worker/runners/base_task_runner.py sha256=XPt8muHGpN_YplY97tt7nID4GFMPlWZ6OVQIFw3lQIk 5844
frocket/worker/runners/part_loader.py sha256=jWIaxDQcOx86T4-29EiGSON1wvyTTi6_craZi-9qkvw 6352
frocket/worker/runners/query_task_runner.py sha256=x8AfQZ6ytfbhHoQIup2VGca3MObYVZogo3zuc8ukxSo 6957
frocket/worker/runners/registered_runners.py sha256=ynvLSbp85oZ3Za3InueBoL_1kFV_4XMxZKKQMyAMAdQ 1201
frocket/worker/runners/registration_task_runner.py sha256=ZR4dzzEIkQJg2b0BuDuzdvn0WBBpME39C47UVWtivsk 11122
tests/__init__.py sha256=E9ra7p9oLUe_-Rma1btARrQHSXBe4ywLo5aY6qAfhF4 604
tests/test_apiserver.py sha256=Vc4FsCnyD_DwstroWJoA7HxJbV_G9mNrHW5y3DqUmkU 15278
tests/test_cli.py sha256=7OlC9_Xdkoo_saeVp4Kr-23LHRY3b9-4lD2My0W3ld0 9742
tests/test_invoker_api.py sha256=AqGOSY0gZn-7WcGZhvvRUYz4rTybERDJrKcIlODNl4o 20915
tests/test_part_loader.py sha256=YWap5_wEUReRiwP85GyOrOgyhSZYUL5PYcUSTVTgjyQ 12759
tests/test_path_visitor.py sha256=y4inEAxpf7OUiwlq_pKpRMFdKzzIsuibuqTqmYyE2fI 8509
tests/test_query_engine.py sha256=SGliDKSJgGhaxmd_-60EmhrOs--DP0R6ag9yUpStFH8 15131
tests/test_query_job.py sha256=IB66NjQo25w3hpqpb5Qna16NML80-Xbkqq_WVgP6aFo 16965
tests/test_query_task.py sha256=0JC6DEGCaCt4cIJl8lGyEupaQoOcooPsABKVPJNml4s 18757
tests/test_query_validator.py sha256=EUIv_OFooYMluMpU9KkzOiwGWPXldHttjkX9OdDinaw 23921
tests/test_registration_job.py sha256=138Pn5oHJfl7FAKHqfesrTuzYlMn3yvluNeahGukvfU 14470
tests/test_registration_task.py sha256=9elZ4BfEr_5o7ARBMYyrL_hbvisIUoCYx9738aJXRVU 9609
tests/utils/__init__.py sha256=E9ra7p9oLUe_-Rma1btARrQHSXBe4ywLo5aY6qAfhF4 604
tests/utils/base_test_utils.py sha256=o-xe0WbdQEH27f824147GAHwyq6TEB-JSPFi0-emF8U 2319
tests/utils/dataset_utils.py sha256=A4JwdIR8VXuGvDj0r2z0haVeeNZCTM17e-GQ98i4RpE 11643
tests/utils/lambda_fixture.py sha256=WmCP7R7RutQT0yNJ6j2PTO5s_zUEtnzsOJjqPmyJxak 1022
tests/utils/mock_s3_utils.py sha256=7evq09yOKKgoCt3XqqQ9F0rTcmLYdfzuyZoIXzqUAj8 1894
tests/utils/redis_fixture.py sha256=YzTk0aRDIihH9g_QVEeyGS575YA5136WqSZeQUVQ6P4 1381
tests/utils/task_and_job_utils.py sha256=VtDis-bJHYwZ5Qc_DORmi1F8hjXpiF2kuR2NCkpKA_U 9769
funnel_rocket-0.5.3.dist-info/LICENSE sha256=psuoW8kuDP96RQsdhzwOqi6fyWv0ct8CR6Jr7He_P_k 10173
funnel_rocket-0.5.3.dist-info/METADATA sha256=q0VNR9qVtYbkPZlboloeHrxr3ZBgOCtJ_LY9qMiFa78 16902
funnel_rocket-0.5.3.dist-info/WHEEL sha256=OqRkF0eY5GHssMorFjlbTIq072vpHpF60fIQA6lS9xA 92
funnel_rocket-0.5.3.dist-info/top_level.txt sha256=bdMQ7A3xTcGKgsuj2vEB-XZv0lrinfigfXQXnZb3vm4 31
funnel_rocket-0.5.3.dist-info/RECORD — —

top_level.txt

dataprep_example
frocket
tests