flowetl

View on PyPIReverse Dependencies (0)

1.31.0 flowetl-1.31.0-py3-none-any.whl

Wheel Details

Project: flowetl
Version: 1.31.0
Filename: flowetl-1.31.0-py3-none-any.whl
Download: [link]
Size: 32389
MD5: 002890d336ce2dd66449e8b29cfec9d6
SHA256: d505dcac132f017fb4dd172f208fa0f25d5e83f7ea70816e54f607108628f217
Uploaded: 2024-11-26 13:10:59 +0000

dist-info

METADATA

Metadata-Version: 2.1
Name: flowetl
Version: 1.31.0
Summary: FlowETL is a collection of special purposes Airflow operators and sensors for use with FlowKit.
Maintainer: Flowminder
Maintainer-Email: flowkit[at]flowminder.org
Home-Page: http://github.com/Flowminder/FlowKit
License: MPLv2
Requires-Python: >=3.6
Requires-Dist: apache-airflow[postgres] (>=2.0.0)
Requires-Dist: click
Requires-Dist: structlog; extra == "dev"
Requires-Dist: pytest; extra == "dev"
Requires-Dist: psycopg2-binary; extra == "dev"
Requires-Dist: pandas; extra == "dev"
Requires-Dist: docker; extra == "dev"
Requires-Dist: versioneer; extra == "dev"
Requires-Dist: pytest-cov; extra == "dev"
Requires-Dist: black; extra == "dev"
Provides-Extra: dev
[Description omitted; length: 96 characters]

WHEEL

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

RECORD

Path Digest Size
flowetl/__init__.py sha256=t5uEXHkgyCxYUR48LF5OcSkK_113wTD-Pvq6y5-jL0c 643
flowetl/_version.py sha256=QvnExyzHDSEBzYLUK2sv9MG0DejP3xQnbwH1pc9_6l4 498
flowetl/cli.py sha256=ArBNZffSCwvSwA3C7nS5DK6j9FpCHzl9nVqFX0jtzs8 801
flowetl/util.py sha256=2qC1LrvqKsmZEd2p5dm3MtqaxueMAqjvu7Vi8D1OA90 15766
flowetl/mixins/__init__.py sha256=OKfz9uohOlq9sL4XsCan_Yg7pHbkP1z6I7zB3YZ4PqQ 355
flowetl/mixins/fixed_sql_mixin.py sha256=kaKGzZGDdyIEl3FA85BehuA7CHKs1FosXMr9McQDNV4 1228
flowetl/mixins/fixed_sql_with_params_mixin.py sha256=VhamEEAhGItM6TSaXMAeAYqutF2HvnOGmuE9FcuaKSU 1611
flowetl/mixins/table_name_macros_mixin.py sha256=y30bxpLlmmJlN0KAdnYDXhyLmAxghgsm4IV7uQ0FUFI 1429
flowetl/mixins/wrapping_sql_mixin.py sha256=eBz77DfPff7eVGC37qF4AYAvRMKaDBUp2_EynrpFm_U 1301
flowetl/operators/__init__.py sha256=s3Vm_NAgCerZyPzd8-nC9NMkRtSbFf7D6hKGL0fey0Q 372
flowetl/operators/add_constraints_operator.py sha256=nIRVoG3hkOyqsnoJDQhceQe4h2PYrWEzx70ey_DAhOQ 502
flowetl/operators/analyze_operator.py sha256=fSMnrk4liMTeDeImjkeI54VBNvhWcFe3guSr19LjdAY 895
flowetl/operators/attach_operator.py sha256=3AwnmZpSgCpA0cKBlxQ67w6juuW_Ab4vrH97k2GmV-Q 690
flowetl/operators/cluster_operator.py sha256=DGrF0DWGob1udAaEkScRyjrVo7TBImQX2vTGLpIRe4g 751
flowetl/operators/create_foreign_staging_table_operator.py sha256=6clrFTdtrQHdO7EFR1dXADIUHk8ZN2iN8pPdtS1PNJQ 3585
flowetl/operators/create_indexes_operator.py sha256=FCe3fADncOZXXI2KHL9mX4_4Zwwam1H4yYn76oP5j2o 740
flowetl/operators/create_staging_view_operator.py sha256=Br8lKXXCvc-y4V34NI-0U9DaWoI2_bEs_tiNihasHtw 431
flowetl/operators/extract_from_foreign_table_operator.py sha256=_3zmnwK75cm_yJhJpjTAkJDwISVTQhICLuRoUe2zGEE 578
flowetl/operators/extract_from_view_operator.py sha256=3Ze13bAWBiFAo2UGnleem6NhpElmpXck-AOLhNDp-xY 561
flowetl/operators/qa_check_operator.py sha256=ajm8fat0XT9AqT99DNlSW2bK3eLnNaPQ2ssXfB_cVfY 582
flowetl/operators/update_etl_table_operator.py sha256=OR_zleaWzDVTI5d29H3IdgOqDmM5_vCMqumVfhPvK9g 1031
flowetl/operators/update_location_ids_table_operator.py sha256=sbAnzA6TSBzRJHaUa9i5abWS5usJ1r2DJNN8PQhpmMY 1053
flowetl/qa_checks/qa_checks/count_added_rows.sql sha256=IPi11Ln1KTAoR7YXqpa0v92QeyoNQ420a5kxJYQV9jA 38
flowetl/qa_checks/qa_checks/count_duplicated.sql sha256=SaQrbxQqqyyPBh-vdKztB7-sNuWERDK3AJBmCvOJBfI 789
flowetl/qa_checks/qa_checks/count_duplicates.sql sha256=RXULz7lRyezDgyZ0hCZs3bjdyXPtiBZmzri4rGuXa3c 810
flowetl/qa_checks/qa_checks/count_imeis.sql sha256=70mFjh4eMKI5F7v6AKcCbSO7H5OB8PAUxI1zZVfws_E 142
flowetl/qa_checks/qa_checks/count_imsis.sql sha256=R-MrL-iaCtZBjoXpj_FHs-dyAkeygqWYGWYtRwBjMLg 142
flowetl/qa_checks/qa_checks/count_locatable_events.sql sha256=uhUJN0iCa89kxJR1J3mWDBMiZq_RF-O43_3p0PEPRy0 326
flowetl/qa_checks/qa_checks/count_locatable_location_ids.sql sha256=gANq1fOIXoXAMNWr3VJ4eXGMyY3MeUIoYrV-j_f2vqU 430
flowetl/qa_checks/qa_checks/count_location_ids.sql sha256=h2-vDJNXsZffod82fejTF_Qnu0QF6RpOP-7H5Y-1UJo 87
flowetl/qa_checks/qa_checks/count_msisdns.sql sha256=tETSIt6EmbKZiYbXLIswhPRctTM6DgVahNCxySVVMWs 325
flowetl/qa_checks/qa_checks/count_null_imeis.sql sha256=YPW25eQ-0miHEYLdCmLAJ5L4vdZIv9ZVnqz9nx8CE_A 70
flowetl/qa_checks/qa_checks/count_null_imsis.sql sha256=LoknYgAm-xf_RgYe2iIUuWuHrqaOoOcB13AIWbaJwV0 70
flowetl/qa_checks/qa_checks/count_null_location_ids.sql sha256=cCeTIGBTwNBoBHS8aaUjcVav_KuiSGPOLo_O1ZGIyNo 77
flowetl/qa_checks/qa_checks/earliest_timestamp.sql sha256=VPT3H2qmiNHmZsJXDN0o6PEBdria7fKqqgxheWfuE8U 43
flowetl/qa_checks/qa_checks/latest_timestamp.sql sha256=rQ4jrrfOMlcvLFjYDIyynPU6ppWvjFbZvcGkvphf_jU 43
flowetl/qa_checks/qa_checks/max_msisdns_per_imei.sql sha256=baD6DcgmRobFmfYu-TyPOB4hrVfmByk9fkUvPRU7eF0 317
flowetl/qa_checks/qa_checks/max_msisdns_per_imsi.sql sha256=_N9VLWTZbX-QGogDbHQAoHAln2ultb-mV42k7pZkX0c 317
flowetl/qa_checks/qa_checks/calls/count_added_rows_outgoing.sql sha256=c-wYRxicGphUpDGcUsftpOzTiugfyfoYIOmSmJhBLbI 66
flowetl/qa_checks/qa_checks/calls/count_null_counterparts.sql sha256=aFRs3cJLtrByei2IMK0skcC6d9NcLrgOB0G72jwsF-M 84
flowetl/qa_checks/qa_checks/calls/count_null_durations.sql sha256=znjg-xnXunI1CZxq7zdDKDLqkoXtrZURBXz-tOGmae4 74
flowetl/qa_checks/qa_checks/calls/count_onnet_msisdns.sql sha256=Tg46jDTWCtb3XJRTZ1jAyDNA9gcwcV9r8ZT_PHM7_EU 119
flowetl/qa_checks/qa_checks/calls/count_onnet_msisdns_incoming.sql sha256=lquG1WXyfXLMX5ojK92ou_CtcKc57QAI6Mk8LMQzPrg 150
flowetl/qa_checks/qa_checks/calls/count_onnet_msisdns_outgoing.sql sha256=g64LadUfS7JvFglGGVol2kAsOJjMcMdjj1haOoosCOA 146
flowetl/qa_checks/qa_checks/calls/max_duration.sql sha256=BjgQRZejh4QguI9EV92LwRMiLI58RjhDrQGRbKAWiGs 52
flowetl/qa_checks/qa_checks/calls/median_duration.sql sha256=pAcirlmDS7-MR7p3P7K2F1ofg4wQTlJAIeyUYkx44FU 91
flowetl/qa_checks/qa_checks/sms/count_added_rows_outgoing.sql sha256=c-wYRxicGphUpDGcUsftpOzTiugfyfoYIOmSmJhBLbI 66
flowetl/qa_checks/qa_checks/sms/count_null_counterparts.sql sha256=aFRs3cJLtrByei2IMK0skcC6d9NcLrgOB0G72jwsF-M 84
flowetl/qa_checks/qa_checks/sms/count_onnet_msisdns.sql sha256=Tg46jDTWCtb3XJRTZ1jAyDNA9gcwcV9r8ZT_PHM7_EU 119
flowetl/qa_checks/qa_checks/sms/count_onnet_msisdns_incoming.sql sha256=lquG1WXyfXLMX5ojK92ou_CtcKc57QAI6Mk8LMQzPrg 150
flowetl/qa_checks/qa_checks/sms/count_onnet_msisdns_outgoing.sql sha256=g64LadUfS7JvFglGGVol2kAsOJjMcMdjj1haOoosCOA 146
flowetl/sensors/__init__.py sha256=My6p6xzS0rMGJXwmle6kRo4TLqY0ePpmS1YywPXClCc 415
flowetl/sensors/data_present_sensor.py sha256=sA8mgby4zG8HXF4Nlqv9Q05rpGcHpRjgDHNpMGdEeaI 430
flowetl/sensors/file_flux_sensor.py sha256=Hm6k4ibUmxupQXwlghkIi40x3chSPJxUy70owou61Pw 1531
flowetl/sensors/n_rows_present_sensor.py sha256=6nT1kVOxWL4GalY8mp1vX2wigtQaVPLLueQXuhQTJL4 536
flowetl/sensors/table_flux_sensor.py sha256=m8BWFi-HaT6w72r9TW2iZb2JM5_U0mMwx1IURy8MDf8 784
flowetl-1.31.0.dist-info/METADATA sha256=1MHTzg8NE3WjpsVvn5V0UHXM4L-whL5VXp-mEhq8kVE 815
flowetl-1.31.0.dist-info/WHEEL sha256=GV9aMThwP_4oNCtvEC2ec3qUYutgWeAzklro_0m4WJQ 91
flowetl-1.31.0.dist-info/entry_points.txt sha256=E79BTmCph1C8QaN0lhzrZYNPuvZTPXXrYUHjyVloOik 59
flowetl-1.31.0.dist-info/top_level.txt sha256=kOza6_0849WN7y7uw0ev3q-odJifON-arI8XBFYzHiw 8
flowetl-1.31.0.dist-info/RECORD

top_level.txt

flowetl

entry_points.txt

install-to-dag-folder = flowetl.cli:main