datayoga-core

View on PyPIReverse Dependencies (1)

1.126.0 datayoga_core-1.126.0-py3-none-any.whl

Wheel Details

Project: datayoga-core
Version: 1.126.0
Filename: datayoga_core-1.126.0-py3-none-any.whl
Download: [link]
Size: 79913
MD5: 4f5b155e11164c04f3b01fdde51d0693
SHA256: e1a0209406542cf290148e95e4ae50c38728d4c492bc2ad2cfe56d5989388ec9
Uploaded: 2024-12-24 16:05:47 +0000

dist-info

METADATA

Metadata-Version: 2.1
Name: datayoga-core
Version: 1.126.0
Summary: DataYoga for Python
Author: DataYoga
Author-Email: admin[at]datayoga.io
Project-Url: url, https://datayoga.io
License: Apache-2.0
Classifier: Development Status :: 4 - Beta
Classifier: Intended Audience :: Developers
Classifier: License :: OSI Approved :: Apache Software License
Classifier: Programming Language :: Python :: 3
Classifier: Programming Language :: Python :: 3.7
Classifier: Programming Language :: Python :: 3.8
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: Programming Language :: Python :: 3.13
Classifier: Topic :: Database
Requires-Python: >=3.7,<4.0
Requires-Dist: Jinja2 (<4.0.0,>=3.1.2)
Requires-Dist: PyMySQL (<2.0.0,>=1.1.1); extra == "mysql" or extra == "test"
Requires-Dist: PyYAML (<7.0,>=6.0)
Requires-Dist: SQLAlchemy (<3.0.0,>=2.0.4); extra == "mysql" or extra == "oracle" or extra == "pg" or extra == "sqlserver" or extra == "test"
Requires-Dist: aiohttp (<4.0.0,>=3.8.4); extra == "http" or extra == "test"
Requires-Dist: azure-eventhub (<6.0.0,>=5.11.2); extra == "azure"
Requires-Dist: azure-eventhub-checkpointstoreblob-aio (<2.0.0,>=1.1.4); extra == "azure"
Requires-Dist: cassandra-driver (<4.0.0,>=3.25.0); extra == "cassandra" or extra == "test"
Requires-Dist: certifi (<2024.0.0,>=2023.7.22)
Requires-Dist: cryptography (>=39.0.1)
Requires-Dist: fastparquet (<2024.0.0,>=2023.2.0); python_version >= "3.8" and (extra == "parquet" or extra == "test")
Requires-Dist: hiredis (<3.0.0,>=2.2.2); extra == "redis"
Requires-Dist: ibm_db_sa (<0.5.0,>=0.4.0); extra == "db2" or extra == "test"
Requires-Dist: jmespath (<2.0.0,>=1.0.0)
Requires-Dist: jsonschema (<5.0.0,>=4.4.0)
Requires-Dist: mock (<5.0.0,>=4.0.3); extra == "test"
Requires-Dist: oracledb (<2.0.0,>=1.2.2); extra == "oracle" or extra == "test"
Requires-Dist: orjson (<4.0.0,>=3.8.7)
Requires-Dist: prometheus-client (<0.17.0,>=0.16.0)
Requires-Dist: psycopg2-binary (<3.0.0,>=2.9.5); extra == "pg" or extra == "test"
Requires-Dist: pymssql (<3.0.0,>=2.2.7); extra == "sqlserver" or extra == "test"
Requires-Dist: pysqlite3-binary (<0.6.0,>=0.5.0); sys_platform == "linux"
Requires-Dist: pytest (<8.0.0,>=7.1.2); extra == "test"
Requires-Dist: pytest-aioresponses (<0.3.0,>=0.2.0); extra == "test"
Requires-Dist: pytest-asyncio (<0.21.0,>=0.20.2); extra == "test"
Requires-Dist: pytest-describe (<3.0.0,>=2.0.1); extra == "test"
Requires-Dist: pytest-mock (<4.0.0,>=3.7.0); extra == "test"
Requires-Dist: pytest-timeout (<3.0.0,>=2.1.0); extra == "test"
Requires-Dist: redis (<6.0.0,>=5.0.8); extra == "redis" or extra == "test"
Requires-Dist: requests-mock (<2.0.0,>=1.9.3); extra == "test"
Requires-Dist: sqlglot (<11.0.0,>=10.4.3)
Requires-Dist: testcontainers (<4.0.0,>=3.7.0); extra == "test"
Provides-Extra: azure
Provides-Extra: cassandra
Provides-Extra: db2
Provides-Extra: http
Provides-Extra: mysql
Provides-Extra: oracle
Provides-Extra: parquet
Provides-Extra: pg
Provides-Extra: redis
Provides-Extra: sqlserver
Provides-Extra: test
Description-Content-Type: text/markdown
[Description omitted; length: 5125 characters]

WHEEL

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

RECORD

Path Digest Size
datayoga_core/__init__.py sha256=hKGW4WN5SpoHKfYhGrH-BO8sG6oiRWHzA8xv2wYvWQg 1921
datayoga_core/block.py sha256=t1HEhcneEuMMQ2UDT9rfe-mPcqoG96ZgWJiOz8UPJpA 2843
datayoga_core/blocks/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
datayoga_core/blocks/add_field/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
datayoga_core/blocks/add_field/block.py sha256=q9tRQWcS4xf3p2eHHwCCUVwcfgxrr1FPPLiEGUI5iMs 1085
datayoga_core/blocks/add_field/block.schema.json sha256=GIS1omqXO6CvfhC-z1IXMFqS5xSG0MiWTh1_tQv9CzM 2062
datayoga_core/blocks/add_field/tests/test_add_field.py sha256=VsHsAADWhYJkO4jc0hTICoDxYsNZoXNLbfUDillcBRM 3345
datayoga_core/blocks/azure/read_event_hub/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
datayoga_core/blocks/azure/read_event_hub/block.py sha256=HbJvNRpL39sPPvmn62J_Ma1pci2_gkhQhFn6rwsSqd0 4275
datayoga_core/blocks/azure/read_event_hub/block.schema.json sha256=6WQ8h5J5MEUpkuk4CQTVaWoIdaVec7uljQf_UdAtK_Q 1232
datayoga_core/blocks/cassandra/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
datayoga_core/blocks/cassandra/write/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
datayoga_core/blocks/cassandra/write/block.py sha256=XA6pwjKK8sUxixaVe1xznQbQueYILPYmnNSRFZkjkBg 4651
datayoga_core/blocks/cassandra/write/block.schema.json sha256=w0fVqXjdZx8ZHsBYbphxIsUdmPq3q7ekkRVeXOKgULo 1754
datayoga_core/blocks/files/read_csv/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
datayoga_core/blocks/files/read_csv/block.py sha256=iS5bzxrSGCSvg6ijKkiW2KCEmLwcaYUh5njGVywJVuc 2023
datayoga_core/blocks/files/read_csv/block.schema.json sha256=aHFK6wPVOFsLbjOw6yNt2S0v5MdLXG3Ed9HgnvAOWtk 1665
datayoga_core/blocks/filter/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
datayoga_core/blocks/filter/block.py sha256=IW6KdCFK1HCU6WXK6einnwyJ-ZLloAosjAN_cBqaVJk 1100
datayoga_core/blocks/filter/block.schema.json sha256=QCZDP0zuT6alXJqRgJBzdt8PZ8pfZGjgscweec1llyI 464
datayoga_core/blocks/filter/tests/test_filter.py sha256=eZqsuGsPlytcbuXcjY6Gq0ijtfIblSSI2QzaJH7IKJ8 4200
datayoga_core/blocks/http/receiver/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
datayoga_core/blocks/http/receiver/block.py sha256=qOziDHza8xb5gHJY3oQ3S5Ba29t1Up-_BVsMo_MAqqc 1755
datayoga_core/blocks/http/receiver/block.schema.json sha256=g6tzzoPuMscxMqOduKunkVSe6k1W04yG1auo4mw-uQI 468
datayoga_core/blocks/http/write/block.py sha256=MsvaJgQABCrh1bNCh7HOdyEjoAUwXLa192wklHNFf10 5740
datayoga_core/blocks/http/write/block.schema.json sha256=AZQqKpLswsDrHhcAQHyR1Tk6LlCkNzb3asAxB8N1CoE 5317
datayoga_core/blocks/http/write/tests/test_http_write.py sha256=g8nusVZ796z34CsphupG3jdgxtBUD6kgN9p0bL0FcV8 4224
datayoga_core/blocks/jinja_template/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
datayoga_core/blocks/jinja_template/block.py sha256=hIa_EwSIoCNATNjTu4yIS0ugQO0reNgCvRP7lnkkfws 1217
datayoga_core/blocks/jinja_template/block.schema.json sha256=IhDOTf_HAQb37WpP3AzJ7QxUaoV0JDGspE83zHYctaQ 571
datayoga_core/blocks/jinja_template/tests/test_jinja_template.py sha256=cwjxKM56QWnO9Raz2Q0JyNVIAf1Da0VvFJxhfxCJPFI 2102
datayoga_core/blocks/map/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
datayoga_core/blocks/map/block.py sha256=XG2lVvQlpEI99zLnl-bhDbO21mYWgjOwMtdZMFnQl68 1559
datayoga_core/blocks/map/block.schema.json sha256=Z9IFdvFbx06JRvBwtFdviUhzvFQYrWbUWss9fRp2DW4 1167
datayoga_core/blocks/map/tests/test_map.py sha256=7YIetGWmWk0RLoQuWF4NwGa_cH7FWGn52OdNmhI-FPE 6056
datayoga_core/blocks/parquet/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
datayoga_core/blocks/parquet/read/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
datayoga_core/blocks/parquet/read/block.py sha256=tEd3ecx28IsoXWx8fOFWl9tuubJyy3JA9KfsBYqdqyk 1115
datayoga_core/blocks/parquet/read/block.schema.json sha256=FdomFo1xUzuqj4AU35fCossi2und0_gi_RcgOeiB3b0 352
datayoga_core/blocks/parquet/write/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
datayoga_core/blocks/parquet/write/block.py sha256=8un8AnJ90QTwkng5kHZAAx7kYhqhO3JZlgwV0dbpmBQ 1271
datayoga_core/blocks/parquet/write/block.schema.json sha256=YG0zlr9WcGPnc0SOZNs6wr8cw52T7Jt3h2qjJLM3lMQ 352
datayoga_core/blocks/redis/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
datayoga_core/blocks/redis/lookup/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
datayoga_core/blocks/redis/lookup/block.py sha256=0wkSsv5upCAVqzrEJ8cuqe6QYnJAo6dtJIePwFAuM7Y 2603
datayoga_core/blocks/redis/lookup/block.schema.json sha256=n51B1llbWgUqXdAp_ufu6Y74e1SedFNQwVE0nNA6UiY 888
datayoga_core/blocks/redis/read_stream/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
datayoga_core/blocks/redis/read_stream/block.py sha256=B4chfxe0PMBFjsOUv311-oQXvyHIhempp4uHbA8HoK0 2605
datayoga_core/blocks/redis/read_stream/block.schema.json sha256=GBOHZcJmrIIi7bjV34SspZ8FvaLxPjT2LET4Z8nrHEk 586
datayoga_core/blocks/redis/utils.py sha256=piRTr0Bzb06RFc7dj0Spa6qZ6bD26xcBaduWHOK-iNM 3020
datayoga_core/blocks/redis/write/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
datayoga_core/blocks/redis/write/block.py sha256=3gQJ-NTUBNpYGyif3sBj_WiELV1Z6ryyDNpG--hz3Nw 2113
datayoga_core/blocks/redis/write/block.schema.json sha256=HBHEDJsLVmOd4fS3zDd10XCWHfKZ88jgn-V043loZUo 886
datayoga_core/blocks/relational/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
datayoga_core/blocks/relational/lookup/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
datayoga_core/blocks/relational/lookup/block.schema.json sha256=m18bGMwtQYXs9DeRA0RaK6RemnFgJAL4WLuK9CA4QBE 2211
datayoga_core/blocks/relational/read/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
datayoga_core/blocks/relational/read/block.py sha256=_PA3V4zQopZ2xfvUtKpr_UGjsq7mmvSCswHfwGfiKAw 1612
datayoga_core/blocks/relational/read/block.schema.json sha256=7CrfAMRuU7leronq2P-f4-Zl51JaSgjQireM1c4gp14 1321
datayoga_core/blocks/relational/utils.py sha256=peszTFziXMUE2eWioY178yxFeXAaFjXgtPb_BnZsdj0 5492
datayoga_core/blocks/relational/write/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
datayoga_core/blocks/relational/write/block.py sha256=xwfbx8l_t_EvGGJDYmTOSQaZsyRrU_nIRhregue_EL8 10876
datayoga_core/blocks/relational/write/block.schema.json sha256=dSf9DglTuEHwQ_OsOUwFON9VmBGAFtonwgtApCb4hhk 3287
datayoga_core/blocks/remove_field/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
datayoga_core/blocks/remove_field/block.py sha256=m1KeV0VdAWMMp2jaR2Nz4ha3BHQP6kpEpzWcE9dwCUo 1182
datayoga_core/blocks/remove_field/block.schema.json sha256=MFE6GZ2yagdDmgxMQOBPGWv5mWM2npx1ARZR4ZbG21g 1182
datayoga_core/blocks/remove_field/tests/test_remove_field.py sha256=AhmVopCvdf-8TD8M3ih_C9b1N_Bo_hkzO8gtU-xqLBU 1893
datayoga_core/blocks/rename_field/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
datayoga_core/blocks/rename_field/block.py sha256=1pnuzcX-AvqmMcdNw5ELzbOcT4cdML2M0t_Y4Rq4VDw 1942
datayoga_core/blocks/rename_field/block.schema.json sha256=hUjV92LsoRTwFObt2wxedb9O4mkFiODvcRmWipEIJ8Y 1716
datayoga_core/blocks/rename_field/tests/test_rename_field.py sha256=JRnobmxa2laNhxMq0kDy0UZwUtt3NyTALf8whzPuUwQ 2279
datayoga_core/blocks/sequence/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
datayoga_core/blocks/sequence/block.py sha256=8AsZTc-i4SKfv6fMCrR-RzYmisG0uethKfTMXCrLb5s 436
datayoga_core/blocks/sequence/block.schema.json sha256=bHX5f94OsqO1ApBU33dOiBV04GiudoZklmZ_fj6SPv4 517
datayoga_core/blocks/std/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
datayoga_core/blocks/std/read/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
datayoga_core/blocks/std/read/block.py sha256=UCTXGe38PhBrwuTlf2Sa0--rsc7B8wFVhHBn6qk0yEc 1299
datayoga_core/blocks/std/read/block.schema.json sha256=FrLOGBOereXIo0sotuiyNV2bExv0tus-6djum9KnyMU 75
datayoga_core/blocks/std/write/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
datayoga_core/blocks/std/write/block.py sha256=IeLw8KgbZDFWr8rYEwgwhSmmRmmll6-_TmCYr_hB3NM 870
datayoga_core/blocks/std/write/block.schema.json sha256=ssOcpfuE67P2MEZsKfxqtF3jKYqTM-u92DKLgMzAeIs 76
datayoga_core/connection.py sha256=u2JQvPS_Y456I7jN8gru6MoRb-uklaCH_iPPrqLPEdo 1459
datayoga_core/context.py sha256=apDsibfXy9q48A9iaYra7ycrCmRMwYDBlHePgn28pJ0 337
datayoga_core/expression.py sha256=qI_W5pmJ4rAA-8cJ9MXDlutLBL0OwGJK-lu3FtcDhuQ 7581
datayoga_core/jmespath_custom_functions.py sha256=tyZBD_lvZnsePDcN2pOsNrChBPyeyfmGFtkAr2MHkJw 8300
datayoga_core/job.py sha256=Gb6B51Mg1n7CbOX06juWjl7tJutQW90eqC3I5nf5GkI 10313
datayoga_core/opcode.py sha256=eqlnqE7OnQZawEwldnmCqaP7wD9L6iEigHITg8TluGM 116
datayoga_core/producer.py sha256=a8jgrjvVe7V2k83B9nHFgMSCW40NV9MwKDnVYHAxS60 739
datayoga_core/prometheus.py sha256=1yOHKVzYRQO97tDVhuhBegOanBxLwn6_OsJdOxWwxD0 522
datayoga_core/resources/scaffold/.gitignore sha256=3t06Ny6J6hWz4929auBvktA8oH9gMkNnWBxigHek-iU 23
datayoga_core/resources/scaffold/README.md sha256=AHz5w5crIQoKCardqwUr7zxrvP7fylzw1DJeykSIbR0 967
datayoga_core/resources/scaffold/connections.dy.yaml sha256=yud5uiD8P84iZBMPejQwaObWbFF96SZJRRaAZMSPuQ0 151
datayoga_core/resources/scaffold/data/sample.csv sha256=alP7vZUz5iGhAe6YlyrJbUa8D6L1gEQSsF90LRV5CrI 188
datayoga_core/resources/scaffold/jobs/sample/hello.dy.yaml sha256=cKTrwRQ5juvbS-6KLzDTeIWIVvatoJZTz3OsGBk2tvU 444
datayoga_core/resources/schemas/connections/cassandra.schema.json sha256=8LpbF6XiuSmQDR65iwq0VykL_PlbYUJcTk-36fKCnkY 1078
datayoga_core/resources/schemas/connections/db2.schema.json sha256=exi5Yg8thh2tvIUWpP74xOjqHHeX9JtCT57KJuhuJv4 1403
datayoga_core/resources/schemas/connections/http.schema.json sha256=w9JKHA8JAKKXSY_BbdjnIyOmtcUzXFd3sLEvri2JwX8 2427
datayoga_core/resources/schemas/connections/mysql.schema.json sha256=PcgxhfVp_TDW6NPy7x2-GGDDloRRS9qpQ8TI7TA5bak 1405
datayoga_core/resources/schemas/connections/oracle.schema.json sha256=GmXOXjhBs0ipVPqUl19ae3jJ0riUUSLYd_GTmSoPFTA 1701
datayoga_core/resources/schemas/connections/postgresql.schema.json sha256=fW0FaB0XSMY6lZEN8yORybz_Ydqii6_71syz_QrIOns 1521
datayoga_core/resources/schemas/connections/redis.schema.json sha256=sXZeEJ6iE07ZTY-caOwxRvQriGF7NA5yBhJTriLfOp4 2138
datayoga_core/resources/schemas/connections/sqlserver.schema.json sha256=Lsg7Ib6fikx5VtGC9UHCF23WIf1WOp-UNW7XCcuFah4 1259
datayoga_core/resources/schemas/connections.schema.json sha256=S6yc1fDnKyRJA94HHn3glfICigojJhUAE1FCVJT7-lM 1177
datayoga_core/resources/schemas/job.schema.json sha256=cADdurNUaqP8wKD42VsRKURBRuUtt0VOhGggN6LWJqk 1833
datayoga_core/result.py sha256=r-xTCUPFHlvcoPPsByyeZSlyvJBHXNdG3dGGkBjKx4g 1048
datayoga_core/step.py sha256=O8D0RI8KEb7GoTv5B-iwxdKc3isKl2YCpg1PIXJ8uB4 5505
datayoga_core/step_buffer.py sha256=RIsIBky-V33qOJyvWje8neHjoFntY65nTWCWI9HRkeQ 2112
datayoga_core/utils.py sha256=UBAbMy9kFaPmoR9zhpZgrW5DEwfbjPk1kr6j1LQH57Q 6444
datayoga_core/write_utils.py sha256=aaQDLV4W_cVBdDNJemkmiaswUZP-RyPXclSrgmgJEXk 2536
datayoga_core-1.126.0.dist-info/METADATA sha256=Kq_LjAQWNZLIIV6Z4EHv8F0D4mnoiueI8HcsvvA6jkM 8367
datayoga_core-1.126.0.dist-info/WHEEL sha256=Nq82e9rUAnEjt98J6MlVmMCZb-t9cYE2Ir1kpBmnWfs 88
datayoga_core-1.126.0.dist-info/entry_points.txt sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
datayoga_core-1.126.0.dist-info/RECORD

entry_points.txt

[empty]