buildflow

View on PyPIReverse Dependencies (0)

0.3.1 buildflow-0.3.1-py3-none-any.whl

Wheel Details

Project: buildflow
Version: 0.3.1
Filename: buildflow-0.3.1-py3-none-any.whl
Download: [link]
Size: 622559
MD5: 4188ef45f4cca8ffd8b4993b669fb9a5
SHA256: b37b5f152f39ea6f8768a243bd3ed9cabf877bfbd7d67e7bf35c63e04c6e3ce7
Uploaded: 2023-12-21 17:19:06 +0000

dist-info

METADATA

Metadata-Version: 2.1
Name: buildflow
Version: 0.3.1
Summary: BuildFlow, is an open source framework for building large scale systems using Python. All you need to do is describe where your input is coming from and where your output should be written, and BuildFlow handles the rest.
Author-Email: Caleb Van Dyke <caleb[at]launchflow.com>, Josh Tanke <josh[at]launchflow.com>
Classifier: Development Status :: 2 - Pre-Alpha
Classifier: Intended Audience :: Developers
Classifier: Topic :: Software Development
Classifier: License :: OSI Approved :: Apache Software License
Requires-Python: >=3.7
Requires-Dist: asyncpg
Requires-Dist: black
Requires-Dist: boto3
Requires-Dist: cloud-sql-python-connector
Requires-Dist: dacite
Requires-Dist: duckdb
Requires-Dist: clickhouse-connect
Requires-Dist: gcsfs
Requires-Dist: google-api-python-client
Requires-Dist: google-auth
Requires-Dist: google-cloud-bigquery
Requires-Dist: google-cloud-bigquery-storage
Requires-Dist: google-cloud-monitoring
Requires-Dist: google-cloud-pubsub
Requires-Dist: google-cloud-storage
Requires-Dist: grpcio (>=1.56.0)
Requires-Dist: itsdangerous
Requires-Dist: fastparquet
Requires-Dist: opentelemetry-api
Requires-Dist: opentelemetry-sdk
Requires-Dist: opentelemetry-exporter-otlp
Requires-Dist: opentelemetry-exporter-jaeger
Requires-Dist: pathspec
Requires-Dist: pandas
Requires-Dist: pg8000
Requires-Dist: pulumi (==3.98.0)
Requires-Dist: pulumi-aws
Requires-Dist: pulumi-gcp
Requires-Dist: pulumi-snowflake
Requires-Dist: pyarrow
Requires-Dist: pydantic (<2.0.2)
Requires-Dist: pyyaml (!=5.4.0,!=5.4.1,!=6.0.0)
Requires-Dist: s3fs
Requires-Dist: sqlalchemy[asyncio]
Requires-Dist: snowflake-ingest
Requires-Dist: ray[default] (>=2.4.0)
Requires-Dist: ray[serve] (>=2.4.0)
Requires-Dist: typer[all]
Requires-Dist: redis
Requires-Dist: watchfiles
Requires-Dist: aiobotocore; extra == "dev"
Requires-Dist: aiohttp; extra == "dev"
Requires-Dist: botocore; extra == "dev"
Requires-Dist: isort; extra == "dev"
Requires-Dist: moto; extra == "dev"
Requires-Dist: pytest; extra == "dev"
Requires-Dist: pytest-cov; extra == "dev"
Requires-Dist: ruff; extra == "dev"
Requires-Dist: pre-commit; extra == "dev"
Requires-Dist: setuptools; extra == "dev"
Requires-Dist: websockets; extra == "dev"
Requires-Dist: wheel; extra == "dev"
Provides-Extra: dev
Description-Content-Type: text/markdown
License-File: LICENSE
[Description omitted; length: 5694 characters]

WHEEL

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

RECORD

Path Digest Size
buildflow/__init__.py sha256=ukYy-vanQrcsY5RaSyrhRWopgUCXJrvVnqr1ffZG1ug 340
buildflow/requests.py sha256=_eOgY1vC-uB8e5qJFZeQk9rX5MegyKv_mme1ibVRTFU 106
buildflow/responses.py sha256=ZoBvSbDXMly4m3iSRUHBkaxEfuuS3mc8nXVjYs4XIAo 503
buildflow/cli/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
buildflow/cli/file_gen.py sha256=CQ9XdrONm7jZ3QAoMI8i5CEKYl66fqXk44aLHGCO3bg 6703
buildflow/cli/main.py sha256=0HRU-EsBu7kJ4XZrVnBNyWCUkwJ9PYOzdqjHMJqJg_Q 15648
buildflow/cli/utils.py sha256=AYQLLnHMNCjthPW5YaC8U0MdIapNqSS8DYP2UBiavC4 1866
buildflow/cli/watcher.py sha256=garpe4CO1VZ0zOkjEABcwKEitagSB9VxmPEy39pGUis 2916
buildflow/config/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
buildflow/config/_config.py sha256=jiJKUcDXy0lzUeWp5wLJcsTngVpXJhLQGaq61Wjwj4M 492
buildflow/config/buildflow_config.py sha256=LmKVL3dTni4dcYH3y9Z2cO_jDf_6EYdGMRL1QilAD8Q 3103
buildflow/config/cloud_provider_config.py sha256=mQDpfMIbHqNodLcoYnxeNghHc2fR0dvPAz4Pd51lu2c 2688
buildflow/config/pulumi_config.py sha256=g8hz79P_nIzjtTQ7wsjE6nrZsyRfH6GBANniTqU2H7E 4377
buildflow/core/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
buildflow/core/utils.py sha256=bWIpizPOSiDVw0qBkqqhr2yJhk7FS9jhminGWjV9E4E 3421
buildflow/core/app/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
buildflow/core/app/collector.py sha256=OX_58ii2VxMCkzwKkS4xUFn2ZluBUFE3j_1uO0WXr5o 2095
buildflow/core/app/consumer.py sha256=EkObZiFJYLF7TM7UXog3M0Rb0bJt2fXHYveQgrzkavU 1823
buildflow/core/app/endpoint.py sha256=cMZ0enZm52tTyhSyJ9D1PSnvQPSm_cd_j1FXfgHww-M 729
buildflow/core/app/flow.py sha256=TkUH-xInF0gtcRRiYnWpku-_lInlqUgm1b1fvJB3a9E 46530
buildflow/core/app/flow_state.py sha256=-iBCApMli_MINfjUZx7x6wBWWLwbr3AiygdhjHS96UQ 5175
buildflow/core/app/flow_test.py sha256=kDPvjFmeMUJ-UWGluJxjwnWhClHKSl15cNCbM1QdBOU 8083
buildflow/core/app/service.py sha256=8IHPi52wszv3GaJzXA-sWVPIs1D_tRcrwCl8d6nyF5A 1966
buildflow/core/app/infra/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
buildflow/core/app/infra/_infra.py sha256=JxZdj52IzSooD5XacXgVKdA9B6o6nO2jiWLTQ6rMkPE 672
buildflow/core/app/infra/pulumi_workspace.py sha256=1HLIIqgxIPKN_yf9SWBQVtdsya7kZ_nCQfm5TBzSbpA 11446
buildflow/core/app/infra/actors/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
buildflow/core/app/infra/actors/infra.py sha256=ztTHFXhUdQluhFw2ockEZ72PLNeLIVfiqG07_zKq7Wk 7236
buildflow/core/app/infra/actors/infra_test.py sha256=tU_jqRVib6cIeVGCWG-Yc3AHJDZL9dunS4TOz91c1kM 6986
buildflow/core/app/runtime/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
buildflow/core/app/runtime/_runtime.py sha256=V5fsGoYTjyvJrfJj5txjRdDke2DYF5TaFC3UMmzVSWc 1816
buildflow/core/app/runtime/autoscaler.py sha256=HpSd1XEKx32JykEilkMazfL0jk1MspWNWX-FLETMGJY 11372
buildflow/core/app/runtime/autoscaler_test.py sha256=wj9MenbrXtBFVIxnOHTUv4FMjxpYcPQfV2H--eJKwVs 8802
buildflow/core/app/runtime/fastapi.py sha256=itJ49bl6nNk8Gu8j0KFY95H0Buf1hS4Vpa_UOTgUS-4 9290
buildflow/core/app/runtime/server.py sha256=hBv4DkBLV857rxbPdPKjBJsramFqTsP71bhEZNV_aCA 4006
buildflow/core/app/runtime/actors/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
buildflow/core/app/runtime/actors/process_pool.py sha256=vSb1D-FJa4UllxbAQsCtVNzAPUnAwa7MbJCXlTZUWBE 7430
buildflow/core/app/runtime/actors/runtime.py sha256=NMeKJpM27d_vEmKob1b4KfCxwGXMaKsZ92tDqkDZaac 12770
buildflow/core/app/runtime/actors/runtime_test.py sha256=8TK8xMhhqh4SFpDhruh1K01dql_jeUW6jqangJGXUGI 13495
buildflow/core/app/runtime/actors/collector_pattern/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
buildflow/core/app/runtime/actors/collector_pattern/collector_pool.py sha256=NtEKe2tRE3fgu53Y08K_0m3NT6bXMX1mTzlwZnoSIz4 4631
buildflow/core/app/runtime/actors/collector_pattern/receive_process_push_ack.py sha256=AP0sboeM09Q1u1QvPCTS72Jc3hoCDVy0TrF2Un1NYDw 6285
buildflow/core/app/runtime/actors/consumer_pattern/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
buildflow/core/app/runtime/actors/consumer_pattern/consumer_pool.py sha256=yU_EinqtA5RLLgA5TWLAxCz92SEf-8hDY6L8irzPwcw 11321
buildflow/core/app/runtime/actors/consumer_pattern/consumer_pool_snapshot.py sha256=9jK5Qc0C8AbIB6XfhuvZm72mqJ1BfiWV5QIQIfDRCL8 2240
buildflow/core/app/runtime/actors/consumer_pattern/pull_process_push.py sha256=H6EMM_8C_DtF8h1FlLduNQLQGMGRg4ffKpG-soHVCzg 14393
buildflow/core/app/runtime/actors/consumer_pattern/pull_process_push_test.py sha256=08IXkJpRvcjtC4xdzFbEt2g9mc9VSglRnmDBVtiviqw 9376
buildflow/core/app/runtime/actors/endpoint_pattern/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
buildflow/core/app/runtime/actors/endpoint_pattern/endpoint_pool.py sha256=5t7HG6S_hC9EMMteAt3KxNq3YirLRqqTz_0IYvoAQcA 4761
buildflow/core/app/runtime/actors/endpoint_pattern/receive_process_respond.py sha256=VPXGAg1wPnKq-CTPPQdptl3ErheSI-hYjXNXID__RLA 5598
buildflow/core/app/runtime/metrics/__init__.py sha256=NvgT1iImxWMiFyAnYzZQDJ3k5i8O46EYWkCScGBbEOA 160
buildflow/core/app/runtime/metrics/common.py sha256=-LhMeU5jGm7D1yQKFEN7wFXGKSZLHiGZAQAW_A986GU 1095
buildflow/core/app/runtime/metrics/metrics.py sha256=lkXkiJntcmiOyffZUWXq5tTnJ2xAny8WiivH4kNrtVs 7357
buildflow/core/app/runtime/metrics/metrics_test.py sha256=XwMaYN8Q3nrzvgx6f6ZVII9KHzPqDoO93pgur-RFV8U 2462
buildflow/core/background_tasks/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
buildflow/core/background_tasks/background_task.py sha256=4ijBixqnCaoyHtsolkqrCPLhzbybbhaPDg4BVXWdBAM 407
buildflow/core/credentials/__init__.py sha256=KOobmT3nK5eslRo7X5iDvE5RS3ZUoDfVvW0EFamKRTA 190
buildflow/core/credentials/_credentials.py sha256=thgnAqmSLNgnV2QwWXG_NaWdM6cXH60w-zxQU8SVXPU 347
buildflow/core/credentials/aws_credentials.py sha256=TJrrQE2DunQ7SyDslaQutB2p8k3tXBMskvJ3w-Uf05I 588
buildflow/core/credentials/empty_credentials.py sha256=Hsu74DMEGbsorauZbmetEbo_wMBLNA6GRVY_ITQCYmE 243
buildflow/core/credentials/gcp_credentials.py sha256=q5eE7UaNEeA6L-zP9T4ZmUHhT9KF-TuJ7C1Fa2dp2PM 1602
buildflow/core/infra/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
buildflow/core/infra/buildflow_resource.py sha256=1UoE2aiIetSMmHN92PQmtj8nvUKjlEi9EU0iwyz9iEU 1036
buildflow/core/options/__init__.py sha256=S_jwEyd0TPRoTW2jL_0pftflaTAWTb6z-5apkjG66h4 217
buildflow/core/options/_options.py sha256=Y3wqRts6NnUuUz3rwP_ZW2X8nGsab64A5m-mbVUODW4 359
buildflow/core/options/credentials_options.py sha256=T01FAdsMUpJ1XLG7u5JpftHNn2rbl3ZnVGEsrt3bPvM 1262
buildflow/core/options/flow_options.py sha256=zmGIPOgazdaZRwVepRa3l27ZBzJgnDv2qJEQcUQTlsc 3660
buildflow/core/options/infra_options.py sha256=FvwKvFUJjtARcmC8WxcoVOodU5ef4xKV1vVvXUHlMac 1052
buildflow/core/options/runtime_options.py sha256=Ke-36a--qvL9T-yXim8vA7-19EcGyjBU3KytEPOGoaE 3348
buildflow/core/processor/__init__.py sha256=vGmh2bHU7NrkdgE0rZdxJb54JN_0SIXtkCIhEbAEPIM 62
buildflow/core/processor/processor.py sha256=ewL-1xMct4NSRT9SGQH9yJH2vmGiQKXAFdph08BbzlU 1409
buildflow/core/processor/utils.py sha256=U6Pv7aXnZxahCBUOnHPuUHZsTRBc2YgJanGdru6dIY0 2911
buildflow/core/processor/patterns/__init__.py sha256=1-YmahzIwKO_p9Tl-ozdMq5JrDZwqPJpCXZHo86zyB4 53
buildflow/core/processor/patterns/collector.py sha256=hJ-8BArIm7RK7BdozsaNPOKXVO8KlB1xrmkkAA5ikzM 1394
buildflow/core/processor/patterns/connection.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
buildflow/core/processor/patterns/consumer.py sha256=nmpRy7DDjyjtjzVuFUQh78-NMuwzKi9kcRO4v5fJTFs 957
buildflow/core/processor/patterns/endpoint.py sha256=L0UIVq4bMF1cvoCQAqiJemqDtusckFLyf53gtszF3MQ 1331
buildflow/core/types/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
buildflow/core/types/aws_types.py sha256=ohVesqSQxNoRy74WS3GdNKqvpl4PLKWRnozNLB6wVeE 75
buildflow/core/types/clickhouse_types.py sha256=RuEV6mCZJT6U9cbkN609sGJCt9PJ5U0lLhUAAAsdV_s 134
buildflow/core/types/duckdb_types.py sha256=q1fwh3o2BVV0Et-WzdZHlqHPpP_4DeCaE6G59CyJocE 51
buildflow/core/types/gcp_types.py sha256=G00rqSsKIp_0QxUBqSRHax-zaS38ROTSzESFtek_ZYc 718
buildflow/core/types/local_types.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
buildflow/core/types/portable_types.py sha256=Qyvwr4n7DxAuOVnXLhoNI2fcS-x5p0v9hxS5xMC_zNo 715
buildflow/core/types/shared_types.py sha256=yqz-z8Loi8oSbptOGrCb1CIhpvVgF2TMEzp8-jHUqYw 15
buildflow/dependencies/__init__.py sha256=7dreMoG8Ck1H_WyU370cr5xZGU98AE1WZqLCe5gOK_g 49
buildflow/dependencies/auth.py sha256=wIqqFGTD-czGM_om6FZugK2Sfoz-mLksrvjS2zPZ6YQ 2303
buildflow/dependencies/base.py sha256=X6M0GTsVJwSCoxdzSuFZzBU7_2xQguxZK-1OVkkXBCk 11093
buildflow/dependencies/base_test.py sha256=ojo28OUgnnDC0lBT7pcmyOWV1Prea5EWeTOV6X2aOwk 5778
buildflow/dependencies/bucket.py sha256=BQzZuZcrCyxZJJiRLFxFEu146foYArV8sjvACcYM-Bc 1491
buildflow/dependencies/flow_dependencies.py sha256=dqEn-cJtdX1k9bPUusmA1lsYJewx4oUggyxRM5AIQY8 280
buildflow/dependencies/headers.py sha256=Y9ZMH4KQXcvUWqR08PyOaaFHG5_0vF0fIRc1h17hylY 2994
buildflow/dependencies/sink.py sha256=Ob9eDvofXvtAN2a5zaw7Qo9Zn1MwvSdJDh-CXPXRJY8 1467
buildflow/dependencies/sqlalchemy.py sha256=GTexiscnfXZJNOIaPEUb57Vxdp2h0Rf-KxTSCkKOBQc 5306
buildflow/exceptions/__init__.py sha256=JSTYde9Rau-A0PSVUl0_oStf2JO9G4PBfWKaGZNh2HE 39
buildflow/exceptions/exceptions.py sha256=sAh28Unba4kGsrjxqG7ivBJgL9pP_n4MLJKDIKwVtMI 1860
buildflow/io/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
buildflow/io/endpoint.py sha256=WYelkr1dKPsJw4AF8MCdTOfPLhxkTogYAmMjJJ27Ro4 390
buildflow/io/primitive.py sha256=Xb9QxV_OOyu58xxZrcqIxi_5Vbr_C8k2TgaKum2enbw 5036
buildflow/io/aws/__init__.py sha256=7pcCn1quRWNQ56AQJaOpCy4vYtdYwWbvzl06p-jirKY 118
buildflow/io/aws/s3.py sha256=UIabS_1cLpMomtEvctNYcqj_-VAehn29ld9VJlyt6c4 2426
buildflow/io/aws/s3_file_change_stream.py sha256=9R0NlchJA7A55DCZaKb3r5kdOpZwJyyYWSO5NmAlB8A 4934
buildflow/io/aws/s3_test.py sha256=CQMEQBKmOPIn1fovYgBzdpv7aTjSOjGkdXxMSCBXDGQ 1033
buildflow/io/aws/sqs.py sha256=-Kxaz_UYGKTjcxxcXG2ltt2f1wgNDu9OyItpfyAPkxY 2333
buildflow/io/aws/sqs_test.py sha256=rwXYcQSB2sXgW5SkEirQwAqRSMbCCG2aIsgWuxoFQZQ 1232
buildflow/io/aws/pulumi/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
buildflow/io/aws/pulumi/providers.py sha256=ENhM1yrYLEIGaXy3mawOLS89QCqi_tIj6Y_TSggk3fM 788
buildflow/io/aws/pulumi/utils.py sha256=xOD3lFtbCtRxk12IPOJJ7UGdSr-5cnYg3fqSVu3QazE 2811
buildflow/io/aws/pulumi/utils_test.py sha256=Fh8ltTnfGVK6HAQXuGJxxGG43hEClavkbLuwpkg5TQ0 789
buildflow/io/aws/strategies/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
buildflow/io/aws/strategies/s3_file_change_stream_strategies.py sha256=R_-fsZMgpek04a2SJSpxEiGr4g5n-p7EhQ0ZkUgejZ0 3325
buildflow/io/aws/strategies/s3_file_change_stream_strategies_test.py sha256=lvqGFU1Ari0y4WbgetrsE3yjCVT0u-kYia3gBb0BxFQ 8808
buildflow/io/aws/strategies/s3_strategies.py sha256=VsHSlaSVy-CYJu3ppTu_A1kdopQfMIrwwqn9KKggJ2E 879
buildflow/io/aws/strategies/s3_strategies_test.py sha256=B2vdqRWTiY7lQGgUP_iFFDjdyuddgBYapfpsoPc1f2Y 1584
buildflow/io/aws/strategies/sqs_strategies.py sha256=em7HwJi0a6Urf0-tjFtnhdHCWYWuHkTWMABwBKaygag 5857
buildflow/io/aws/strategies/sqs_strategies_test.py sha256=tWayqZENkrj8hoIvjs5PP3cYrSZ7b13OJgv1M3G1VbU 3608
buildflow/io/clickhouse/__init__.py sha256=pNviHyxIOxhb71SWIGQbexrx-qTVP0TtG_ICFHQI0Uk 53
buildflow/io/clickhouse/clickhouse.py sha256=IH4rT7vOX5iYj16NG8ZS3doYpYCIwaD4-4PJEeOpt2k 1998
buildflow/io/clickhouse/strategies/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
buildflow/io/clickhouse/strategies/clickhouse_strategies.py sha256=2B4sHfyK_VqD8_N5YVD-lbxnD_T_7nrk9jlNBuXG9FI 2830
buildflow/io/clickhouse/strategies/clickhouse_strategies_test.py sha256=xUA3W6V-VRKdTwkypN0c38Kr8JC_forIIsPODAFkFHw 1749
buildflow/io/duckdb/__init__.py sha256=WpWNqvlqzqBWBdrmmElw4kZQDjhs1nGWWLqJbFn-ayc 45
buildflow/io/duckdb/duckdb.py sha256=RhsXNLVsEckNhGGmUxNWFnghulFyFNa3V7GqDTnMGzg 1598
buildflow/io/duckdb/strategies/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
buildflow/io/duckdb/strategies/duckdb_strategies.py sha256=jdD4LVz7M-jXTQ6C7o1MbqI7RegUK1kP6mpF-QivZLU 2018
buildflow/io/duckdb/strategies/duckdb_strategies_test.py sha256=5U5mNirpflNHVyrfkg81rLAZbIQ-5FlRbtumF1wA1vE 2856
buildflow/io/gcp/__init__.py sha256=fIr8ezlVW18PoW3JkoHoawzfQKZ8V2hPSGHhrv_W7PE 423
buildflow/io/gcp/bigquery_dataset.py sha256=aR66NsgW0zG316DhM78H-DqOUSQe-YdrnGv3EbPvxXY 1054
buildflow/io/gcp/bigquery_pulumi_test.py sha256=Trbx_Hk-SCw4tQnc-aLmYADC3CbMIBg8afbWD-ZmvfY 3443
buildflow/io/gcp/bigquery_table.py sha256=EvUzElEqVW3az9cW7J0XAm7Wtw999GkY5lwKVq9IHMI 4269
buildflow/io/gcp/bigquery_test.py sha256=l9AtOOn2ZpiIuqRkEYb3yRs5TMUbbcv8qYm2jWmIDJ4 1027
buildflow/io/gcp/cloud_sql_database.py sha256=_buR-l6AWjOwvEpb0pJcb_HLC4ZeVXJe2yjDtKkJ7JM 1053
buildflow/io/gcp/cloud_sql_instance.py sha256=E3HRJ-7Ll_SdOL3UCyn-nwdeSLx8wbG6UYG8-fyILTI 1434
buildflow/io/gcp/cloud_sql_user.py sha256=3fVWxeQ9T5QAvPFXe5mS60IEf8kzvvH1AQQ3UEA5iwY 1114
buildflow/io/gcp/gcs_file_change_stream.py sha256=0IA1bXheJfW_xamuqkY3EwPduaNxepQsquRCs1CT9RM 3737
buildflow/io/gcp/gcs_file_change_stream_test.py sha256=mciT_FRI9HLYho5yggRxlo085jZ0y9uar2U3V-KXGxw 2172
buildflow/io/gcp/pubsub_subscription.py sha256=TGzrahKYFqEoEw5GEgV4XAOlBJlQOi8TUzc9QHDHU58 4934
buildflow/io/gcp/pubsub_test.py sha256=YtMd8A-cccoGNu4mv7WmKtJl9qt8dF5bY29c3Cjg4A4 3019
buildflow/io/gcp/pubsub_topic.py sha256=1QofGaWPEfAHFGj-BCFSQyExOhaA7FbYn7kCzBnnwd8 2127
buildflow/io/gcp/storage.py sha256=U3SFEjX3ULoMeKnag0tRwbvqnHNJ7E5BqDrVBexyI6A 4131
buildflow/io/gcp/storage_test.py sha256=GBDzVZcCNi9IDpHqoI-rCiexO0a8HzE1jm58yPPmpl4 1242
buildflow/io/gcp/strategies/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
buildflow/io/gcp/strategies/bigquery_strategies.py sha256=-LIn6WJKZ3BlQnbPP18v1ehTC7fZBNKQlqunoKXbA0U 2047
buildflow/io/gcp/strategies/gcs_file_change_stream_strategies.py sha256=prvTorS_5_XVO4KNeh1p9g6yjNa9rOFV2XCsqUepSQw 2019
buildflow/io/gcp/strategies/pubsub_strategies.py sha256=j-RFS6N7e35Nd_DQ7ianIxL33gkFw0AfCzSkvtEOL_g 7805
buildflow/io/gcp/strategies/storage_strategies.py sha256=g1mesMre1cg9OxEUZJ3VQKs3ttErhL4oESPo_eBFuvg 963
buildflow/io/gcp/strategies/storage_strategies_test.py sha256=fsixXxtz_lcx-dLoeLf28I8NAB_hJn9i4w14Kh21lPA 1158
buildflow/io/local/__init__.py sha256=1mf-En7kgr_IXqSj8esNFihZDCXfHvvNWZ8TmiBv-YM 115
buildflow/io/local/empty.py sha256=kSRtE_7XocOIlzApnulYr-21QQDbFPNL6gL6Wvtutso 733
buildflow/io/local/file.py sha256=jjmZcNkhGZiDB8kuhxMwYsrqmHQ9vHJjpe2kjeMUA-I 1443
buildflow/io/local/file_change_stream.py sha256=RKH560BXjntv66par_YJcaHXdrPJD9UmLFd1bjglCpc 1598
buildflow/io/local/file_test.py sha256=jcpaXJ0G_-XyqgKWhXp5tnVcnjG9uy5ZR8JK_-4nQDs 2130
buildflow/io/local/pulse.py sha256=nIT58-opEkGuJX7AUGAulNWW1NC0rW1DEBX_XKFdFYs 1136
buildflow/io/local/pulse_test.py sha256=Nqp2Ql4_U_obu-gBkSd6YN7NFSMNrV1Lt7fkslonXas 620
buildflow/io/local/strategies/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
buildflow/io/local/strategies/empty_strategies.py sha256=SYYpBzywFgfFNaxF0wfaB3Do4cKVnOgMLcS8CPI1UAw 564
buildflow/io/local/strategies/file_change_stream_strategies.py sha256=9pN60Z-ZS92maw0i_XeJKO-qKteDrVol0xig3B2MBbA 3068
buildflow/io/local/strategies/file_change_stream_strategies_test.py sha256=raRmCIFlHI1h1-CFRc3pGFfSa-7k1PXo7POXswhA77I 3383
buildflow/io/local/strategies/file_strategies.py sha256=oV6Jb7wg9kZXPALO2YwRw7GbJApC2VwUVQDieIR_XpI 2634
buildflow/io/local/strategies/pulse_strategies.py sha256=t85LGYB2KmMC21HeXfGfkKR4rVY_1Rx2f3A0dhH7B1Y 1315
buildflow/io/local/testing/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
buildflow/io/local/testing/pulse_with_backlog.py sha256=LGw6dc-MbQcF31yaW8RDzUFyk_-q5iA31jrEququsWg 1123
buildflow/io/portable/__init__.py sha256=5FLkvgox2-xmAfGPF2k9btpff7ubm1QJHcs8tSETzb8 175
buildflow/io/portable/bucket.py sha256=pnjYV11Hbpv1EGUm0m20ZjmbzuD6h1vObxITrQQH6TM 216
buildflow/io/portable/file_change_stream.py sha256=uiwbAGZ48A-J1yjLQFsOLFI5fNumw9InvLu4QBZmgV8 2683
buildflow/io/portable/queue.py sha256=hjMeaXyAeNO3K9bj5bbSdzsHQyy3D5yhxQd4n7_DF3U 206
buildflow/io/portable/table.py sha256=N0hC-kTiEbYtAxltoGAATuMctT-GlaNiy_13vJY3Mtw 2066
buildflow/io/portable/topic.py sha256=t3BePNb0NofKot2hIjVG5JclEq3MR43aOoB4THmOmJA 2074
buildflow/io/snowflake/__init__.py sha256=EqWhZBvx6rCCKZDYGGuS_fqCV8iDV9BktVUrk2HqNMw 127
buildflow/io/snowflake/constants.py sha256=oRBaVMkjiBLAr8V16KiKIJE5IbgGnawwWxxGUVs5mPw 119
buildflow/io/snowflake/snowflake_table.py sha256=4MVDT97fsbpJKFGmCf5eHaEQGPWqL7r-ySZohUwShCw 5882
buildflow/io/snowflake/utils.py sha256=q__CXRhLV-CxPWJPp3XAAw3-8Fk8uoeeYe0kHzauB78 1020
buildflow/io/snowflake/background_tasks/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
buildflow/io/snowflake/background_tasks/table_load_background_task.py sha256=W7vxEK2QyT5geIt7MzwgfJYXS-jZPAex2kurpcvS-IQ 7943
buildflow/io/snowflake/background_tasks/table_load_background_task_test.py sha256=phRsrQnhQa5mqsNJ3QF4UARE4M-PNbHbM41R7M2iocY 2324
buildflow/io/snowflake/pulumi/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
buildflow/io/snowflake/pulumi/schemas.py sha256=UG5aTMPamm3mE8RFtL3Uoe-AGvNj7vztmSH9LQoYeDY 1651
buildflow/io/snowflake/pulumi/schemas_test.py sha256=3TnYCc63_jCH7rwpiiUjOVmdFKRPDulp5eUc8sogots 2259
buildflow/io/snowflake/pulumi/snowflake_table_resource.py sha256=pcW8uvoK-33rACMCnIOWGON9-I_z5I5FbcSIdXXG9Cw 5382
buildflow/io/snowflake/pulumi/snowflake_table_resource_test.py sha256=e5T8iwE50N7Tec0cICQdRKvcd6hXsayh3cV4NELo3Y4 4755
buildflow/io/snowflake/strategies/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
buildflow/io/snowflake/strategies/table_sink_startegy.py sha256=dj7_WAHQtdyTP-rrKR2DZHC7rsDDb9ik-NxLaEiFuME 1490
buildflow/io/snowflake/strategies/table_sink_strategy_test.py sha256=MYA0FUyyRyYu81tOHluX_Ch_cU6snbl90kmLObusAmw 1700
buildflow/io/strategies/__init__.py sha256=q2EITbDbbrxBOLnkEzn9bx9qwNqTH6LcIPEf1oOYmko 136
buildflow/io/strategies/_strategy.py sha256=pn1Z3gH7PbuploRZCq4QArJZ0zCWIw2ItxPcHKrydGI 412
buildflow/io/strategies/endpoint.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
buildflow/io/strategies/sink.py sha256=btHLxBOmKJ8Y0o02xczKhy0Q55LrDlzSw31D8DKJ95M 915
buildflow/io/strategies/socket.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
buildflow/io/strategies/source.py sha256=FawgC86o9T6hUlJh9lUJOW6_XnWVECr4DSofJa6wxkM 1610
buildflow/io/utils/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
buildflow/io/utils/file_systems.py sha256=KTji2gc0EoEessP9X_uVe5RZBF-Z0WpxTATaNbzXIRQ 988
buildflow/io/utils/pulumi.py sha256=Se4L0a0yBtS8U11rThXXD5jtr1oAE-lHPxNMh-evyIs 582
buildflow/io/utils/clients/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
buildflow/io/utils/clients/aws_clients.py sha256=gEukpe0m6bBH_H6IRfD0A_1JWZKcNBOr3uLqcOuktzM 2506
buildflow/io/utils/clients/gcp_clients.py sha256=l1ghzZn27dKkw3jPcauvsG2qu7AQdS2k6vfV9CW3FK0 2061
buildflow/io/utils/schemas/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
buildflow/io/utils/schemas/bigquery_schemas.py sha256=eS1Ov1Y-F-fV-40-DWBrE5myB1scviT-vJQQ90oNEXk 3471
buildflow/io/utils/schemas/bigquery_schemas_test.py sha256=gcfqDiW8N7AnF0jP7rtHo4eaNr8Px49cktuvDw3Du_k 5152
buildflow/io/utils/schemas/converters.py sha256=cG0gQFmkr5LIvcl6wxZXTr7ZXc7pIm3B4l7H-XI0HJU 8580
buildflow/io/utils/schemas/converters_test.py sha256=jnWlpdI0e3GJjAzHLk3iVA1PEqrak6i4rPnJREvSkxM 7495
buildflow/middleware/__init__.py sha256=2xEVUZp5nnZ52vnvPzHT5cT5TghzHPWMNMz22jQAsxI 208
buildflow/samples/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
buildflow/samples/collector/main.py sha256=Qt9jhSi1-W0akZlhVtC9BXG0HYIZyaCHXn170mUJq6c 1812
buildflow/samples/collector/schemas/__init__.py sha256=ccWGXaTopucmNPuOIGkDA6bwD3HVNjUYD5VeY7oooU8 128
buildflow/samples/csv_bigquery_walkthrough/main.py sha256=G_VhcohSLu8fbG7hK9Oh6UVuYRNsXpOG4i95lAifnTc 3166
buildflow/samples/pubsub_gcs/main.py sha256=oFb_l5JF4pCFxNerFVbTA-zIvRS4CjMlgaGULE3u4BA 1093
buildflow/samples/pubsub_walkthrough/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
buildflow/samples/pubsub_walkthrough/main.py sha256=4Zu6tYZ__Mme5fN1iCX1XStaOpb6Svr4cUCfh7nnsug 1561
buildflow/samples/service/main.py sha256=BAgpVHe0HbRs8OZxNV6KqmgOyDD2MvfTReeMUBODUjY 870
buildflow/samples/sqs_s3/main.py sha256=SD3XOM4ax5sPlpZ1rxap50fL1HZzb8gVeUkrzj3LwbQ 806
buildflow/static/swagger-ui-bundle.js sha256=uvweEhNUHqHdSHp9-ZvDM-zhuf7DkZI5EBu4aOje3mE 1385195
buildflow/static/swagger-ui.css sha256=UFCy2p7szN-PCWJ_c0t1lnrxumIVaCuBzX6nxXI9YrM 188389
buildflow/types/aws.py sha256=ePbLIIFTPaLS-_XIo8Czv4WbutxdEhhhtvyjfPVOEMg 2479
buildflow/types/gcp.py sha256=uzXJBo0GkdnWf7OMrPdyAWDh_SM3sAbudv1whtn52Iw 1687
buildflow/types/local.py sha256=SLrqpwcSWPweBa11GZh4-Ut2Wx1kIKHxsfDs4VqQX-4 1050
buildflow/types/portable.py sha256=LUQyfPbJoNIiV1HzUWmSocGG22bMlBWj9ZUyt1JqPMc 707
end_to_end_tests/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
end_to_end_tests/collector_test.py sha256=y8-bih3OlVEvlb-5H--AtVTMf4BZDcuqF4ILx4FJP6g 11911
end_to_end_tests/consumer_test.py sha256=L34V0pyKXGLikemo8kknKtwe9NPzJfaHaSW4Yo6-QNM 7926
end_to_end_tests/endpoint_test.py sha256=E5WFuM1MQPU4g0FqavYvhMbm_hZtkPvnHDwBnc63QnU 12287
release_tests/pubsub_to_pubsub/main.py sha256=Mc9GVvuf3GQRcO9QUvSbvx0LCpHHgtQ01DeFw4cvqrY 947
release_tests/pubsub_to_pubsub/pubsub_publish.py sha256=OY50Z4cyYwJLdXkFbmCVjRcxhwpVuYSfhKwZ3a7ZOCY 1516
release_tests/pubsub_to_pubsub/pubsub_validation.py sha256=AiTZShYD2VL7U7JQW45z_oOUCmnR5SXS4QwV5J1glk8 1002
release_tests/s3_file_stream/main.py sha256=snyKZwTrdNxHxT3Q1DHv3ylwlH02AXzgmDqEqsXFoio 4083
release_tests/s3_to_bigquery/main.py sha256=xTe7uewAgXPrCI3hLzcNWBymjp5YX9A0WU4CLKwUNxo 3301
release_tests/sqs_to_sqs/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
release_tests/sqs_to_sqs/main.py sha256=P5tG3TfLAvVeuZRR4g2eHE2E1_4p1pZ50kc_XWbJBHQ 1487
buildflow-0.3.1.dist-info/LICENSE sha256=Lh-qBbuRV0-jiCIBhfV7NgdwFxQFOXH3BKOzK865hRs 10480
buildflow-0.3.1.dist-info/METADATA sha256=rjHxAv-DQ8cZikoeAykeYRAhl27ovVi7z2uC-f5QBys 8121
buildflow-0.3.1.dist-info/WHEEL sha256=oiQVh_5PnQM0E3gPdiz09WCNmwiHDMaGer_elqB3coM 92
buildflow-0.3.1.dist-info/entry_points.txt sha256=6JBBBrCkjv5Zl02ozKihI0Tr0bRVq4KgbzQiSJKX814 54
buildflow-0.3.1.dist-info/top_level.txt sha256=J4YscxvmjSKLrjUUichXip8RnzqJ1gaiDzLqnbbHHHc 41
buildflow-0.3.1.dist-info/RECORD

top_level.txt

buildflow
end_to_end_tests
release_tests

entry_points.txt

buildflow = buildflow.cli.main:main