Wheelodex » Projects » taskflow

taskflow

View on PyPI — Reverse Dependencies (14)

5.10.0 taskflow-5.10.0-py3-none-any.whl

Wheel Details

Project: taskflow
Version: 5.10.0
Filename: taskflow-5.10.0-py3-none-any.whl
Download: [link]
Size: 504262
MD5: 275138792e71e67fb46454aef01dea20
SHA256: bc0988a32ea0baf2afd0da8f620d66d16662696045c1e04bb26bf37a98bea706
Uploaded: 2024-11-14 09:30:31 +0000

dist-info

METADATA · WHEEL · RECORD · top_level.txt · entry_points.txt

METADATA

Metadata-Version: 2.1
Name: taskflow
Version: 5.10.0
Summary: Taskflow structured state management library.
Author: OpenStack
Author-Email: openstack-discuss[at]lists.openstack.org
Home-Page: https://docs.openstack.org/taskflow/latest/
Keywords: reliable,tasks,execution,parallel,dataflow,workflows,distributed
Classifier: Development Status :: 5 - Production/Stable
Classifier: Environment :: OpenStack
Classifier: Intended Audience :: Developers
Classifier: Intended Audience :: Information Technology
Classifier: License :: OSI Approved :: Apache Software License
Classifier: Operating System :: POSIX :: Linux
Classifier: Programming Language :: Python
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: Programming Language :: Python :: 3 :: Only
Classifier: Programming Language :: Python :: Implementation :: CPython
Classifier: Topic :: Software Development :: Libraries
Classifier: Topic :: System :: Distributed Computing
Requires-Python: >=3.9
Requires-Dist: automaton (>=1.9.0)
Requires-Dist: cachetools (>=2.0.0)
Requires-Dist: fasteners (>=0.17.3)
Requires-Dist: futurist (>=1.2.0)
Requires-Dist: jsonschema (>=3.2.0)
Requires-Dist: networkx (>=2.1.0)
Requires-Dist: oslo.serialization (>=2.18.0)
Requires-Dist: oslo.utils (>=3.33.0)
Requires-Dist: pbr (>=2.0.0)
Requires-Dist: pydot (>=1.2.4)
Requires-Dist: stevedore (>=1.20.0)
Requires-Dist: tenacity (>=6.0.0)
Requires-Dist: PyMySQL (>=0.7.6); extra == "database"
Requires-Dist: SQLAlchemy-Utils (>=0.30.11); extra == "database"
Requires-Dist: SQLAlchemy (>=1.0.10); extra == "database"
Requires-Dist: alembic (>=0.8.10); extra == "database"
Requires-Dist: psycopg2 (>=2.8.0); extra == "database"
Requires-Dist: etcd3gw (>=2.0.0); extra == "etcd"
Requires-Dist: eventlet (>=0.18.2); extra == "eventlet"
Requires-Dist: redis (>=4.0.0); extra == "redis"
Requires-Dist: hacking (<0.11,>=0.10.0); extra == "test"
Requires-Dist: mock (>=2.0.0); extra == "test"
Requires-Dist: oslotest (>=3.2.0); extra == "test"
Requires-Dist: pydotplus (>=2.0.2); extra == "test"
Requires-Dist: stestr (>=2.0.0); extra == "test"
Requires-Dist: testscenarios (>=0.4); extra == "test"
Requires-Dist: testtools (>=2.2.0); extra == "test"
Requires-Dist: kombu (>=4.3.0); extra == "workers"
Requires-Dist: kazoo (>=2.6.0); extra == "zookeeper"
Requires-Dist: zake (>=0.1.6); extra == "zookeeper"
Provides-Extra: database
Provides-Extra: etcd
Provides-Extra: eventlet
Provides-Extra: redis
Provides-Extra: test
Provides-Extra: workers
Provides-Extra: zookeeper
[Description omitted; length: 2383 characters]

WHEEL

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

RECORD

Path Digest Size
taskflow/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
taskflow/atom.py sha256=NwpWVIB2UFxPv4sDi30SDadjrhR8ZpZtiOyyvxQIVLI 17342
taskflow/deciders.py sha256=m9qybFHy_zCEo1uLcMltnEkTjY8GZAUDf79rJswV4rY 3402
taskflow/exceptions.py sha256=n-OZG1lIydGJwgxrK5MJSTVK-0tBpP4FrImp0KYU_Ow 11565
taskflow/flow.py sha256=seusvtX5w9ugEtTPzvxHJksSmf1iQqgBl2dfbK8rOKI 4834
taskflow/formatters.py sha256=vJ_vSSW08eNv3v4kQAKSN7Zu91CxL1CyenTg1VMVVOA 7441
taskflow/logging.py sha256=FwO1p_z75Dozk8ieCjAZEnEiq92ErQAAePMVpynx4Gs 1870
taskflow/retry.py sha256=Dk-IcdPi5n2502fzmVMjrWLzlrXp6h1ak_xOpOWoh6s 14537
taskflow/states.py sha256=3MRdAfs0x94QhDjl-RGyTfxAbkL3APtNr_qQf6apqbE 6901
taskflow/storage.py sha256=CSCegSPkrw2QDP6qGrzUYTWBFBX34Kqv0p9hwYId9oM 52114
taskflow/task.py sha256=qw79ho1bhwe5KttSPjalfUlCTfLUjNGc1twNdTFMi4w 10052
taskflow/test.py sha256=T6DfnwU7NcSRLfAYR3QgmGXhRVkYfeH-6JEp2jffQh8 9341
taskflow/version.py sha256=UU8J6gwFErEHh0U8vhI2hxPlTN9k47Fvul2I-4bPp6A 1091
taskflow/conductors/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
taskflow/conductors/base.py sha256=k7E_zu9CIORhODWzwmxh7w8fSNhG6dJaYEfLwIxhxXE 7332
taskflow/conductors/backends/__init__.py sha256=UJS_4cDCt9PT1jrTcmB6cNk4yJpRm1LEoq4rigvaWQ0 1634
taskflow/conductors/backends/impl_blocking.py sha256=WGm0_EZT2UhwEOWEQ3cZ5t4k_ZIWwe-8fstdYX6OYv4 1516
taskflow/conductors/backends/impl_executor.py sha256=Bv_ewIjb_HxG4wpD4Om7WXNazsUMTIEC5cr70PT3kQM 15160
taskflow/conductors/backends/impl_nonblocking.py sha256=PO7Tg2X1N1dJLxj3-AjL1TPxQsSxgiLth0JFhuc5t9c 3014
taskflow/contrib/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
taskflow/engines/__init__.py sha256=W8ik4-Q5TDXYd47IwKEQeSeDbnToJsVIgzs__fS_BSc 1397
taskflow/engines/base.py sha256=pkzWdTIWTdniQTY_BpaDrHmSYs3if6y-ANRVwhhY4Oc 4865
taskflow/engines/helpers.py sha256=oPTpfR4TbQH0QlkO4TO0bQ-zT_XYpvxbHl9moYSkM6g 10952
taskflow/engines/action_engine/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
taskflow/engines/action_engine/builder.py sha256=cYdzNpPSgzpQgO9YCp4T7JgRmpD4L90l1cnld-CRAdw 17015
taskflow/engines/action_engine/compiler.py sha256=26x5yTtNfBcieeaza1n-MiPmUIP-nH2eA_hGOmgy8U8 16164
taskflow/engines/action_engine/completer.py sha256=wjKpUM1QPr_fVnVG_XqA7gw0IKEA_aj3FrEvCITN0J4 9028
taskflow/engines/action_engine/deciders.py sha256=WEKo189CL9Zdg506Sz3Mlxpfp6dqGv7TMcfI07h69Co 7254
taskflow/engines/action_engine/engine.py sha256=kz_9BVD22IO2mEHBc735zUDPCF0Y_hzcAuQqZpUUVCk 29817
taskflow/engines/action_engine/executor.py sha256=sBmKwgDQN9fEZz42T7RB-RYUZvWqfHqC-Y2EsWRGkYI 7749
taskflow/engines/action_engine/process_executor.py sha256=if8kc7Dg3lvT7NwKVe2eqHhksv1pxEPNoI5E80naGr4 27975
taskflow/engines/action_engine/runtime.py sha256=FAUJZsZaADo4t1kRzs0Pf5z2qRjrlNG5GCycUoe4N8U 14604
taskflow/engines/action_engine/scheduler.py sha256=yZEn2z23N-0XNpHtjOs3kxJh4CTpZl-2ASrPsyLP2t0 4048
taskflow/engines/action_engine/scopes.py sha256=u0cmoMycrNZqMebgKqLW2YXBVLukNi9dVqKOFr79lKw 5432
taskflow/engines/action_engine/selector.py sha256=9FKRKOi6mqIn4kfEY2R6Uq6aVzPPsT0DgI1VDVRaZdU 11558
taskflow/engines/action_engine/traversal.py sha256=gLDFNW-yxJxxtbZYgEjudArU8wwGcddcmpq4Sxeu6tg 4552
taskflow/engines/action_engine/actions/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
taskflow/engines/action_engine/actions/base.py sha256=yu8a27VLZeuLnOwx1KbSJ-IrPhyz8fcXy3dyypkihuY 1668
taskflow/engines/action_engine/actions/retry.py sha256=XEEKh0NOp-jasZ0LhZGWpEvJK3bQAuzr_-_E3HoUr1A 4232
taskflow/engines/action_engine/actions/task.py sha256=6vbA3PgPtFP95LmLdKAV-rUug-clH19LKyr99MsCD8o 6042
taskflow/engines/worker_based/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
taskflow/engines/worker_based/dispatcher.py sha256=svp6nHh_qTgX-hiwtyGx0NK1oXk1JY5GmbLKq_7J2dQ 7145
taskflow/engines/worker_based/endpoint.py sha256=w4GeSHdqmrLpywfVdnmgBplrtP8ZmbNRPfomcta8h_w 1715
taskflow/engines/worker_based/engine.py sha256=vLpfgolBiQtauAvnNbMePTmMdTKKD_9rbQUqDTTmOZo 4379
taskflow/engines/worker_based/executor.py sha256=g6JkEr-rq2DtKo96itcpO5qWq2MRH0V7a3eBOFSeosg 13811
taskflow/engines/worker_based/protocol.py sha256=mpK2wN6UN28MDYp5oFH_bMkNSaVCOxPONy9Px9VplbI 20238
taskflow/engines/worker_based/proxy.py sha256=ac_n9AwkqyVl_MQVzYNYNIUmmxNkyPIJBm-hmk80Sx4 9525
taskflow/engines/worker_based/server.py sha256=mPNaKljR90eXmHU6KuvrJPu2KnHjlpjf56xZulq-KF4 11559
taskflow/engines/worker_based/types.py sha256=tCzzadeEDwDw5SBPNY6fSiqmCHilqaxPshL_tcSG1I8 9887
taskflow/engines/worker_based/worker.py sha256=GEGToN5ATKUu7dZ8daWBuCLSBllTm1hkVtOe8tM626M 6331
taskflow/examples/99_bottles.py sha256=Ha7NLEtXAFPGky2zO8KBhuF6j2UN2lqqvMvOT8OV2_Q 8893
taskflow/examples/alphabet_soup.py sha256=g3QHPchnIae58j13mOmjCsBSbcccnYUIMCv0IPmIGmw 3255
taskflow/examples/build_a_car.py sha256=qgOIepvWxfBNiyYYn3NgKvo6C7wcxJIIOyX8BydET3g 6554
taskflow/examples/buildsystem.py sha256=cWJ5elM16ImGfq6EeJxvVy1wCX0g6YslIEyWf4TOijc 3909
taskflow/examples/calculate_in_parallel.py sha256=eCeRAj0h7QsHgd21UpRhMDJWRYO5PcvjPQZ6cTereJk 3917
taskflow/examples/calculate_linear.py sha256=4o-8RmsuRVAj-lv6BhVZiUETjQqKJWoMcMDN-GFakNE 4614
taskflow/examples/create_parallel_volume.py sha256=ap84aAvj0ztn0q7UjvzPiQZfcPH5wke9pbK7TzKIShg 4336
taskflow/examples/delayed_return.py sha256=fy1Kzdm4baVvsZ3Z-KxlEN7J51n9ZdsyRFfNJqpKSaU 2846
taskflow/examples/distance_calculator.py sha256=IobFjbqtjLxhPOXwHlsfy51trEJP_6WVuPLlWLZ7ETg 4453
taskflow/examples/dump_memory_backend.py sha256=ptRZS_jclIoUAALu5yUDy_bnkUBOuVPS1Sx4VY5MDX0 2123
taskflow/examples/echo_listener.py sha256=wEWRTuGm_ZkWMFs14Dd9IJoQ_tS4Lkxre--zYOEh1Sw 1908
taskflow/examples/example_utils.py sha256=r2a4uYxlryyllYjPXvM4y6nz53dhPnasd8Eq1dSZbas 3312
taskflow/examples/fake_billing.py sha256=ffflnkBRU_t8V3QKmRGM7tW-oTBNFt0g5bxY_QFn3Xg 6832
taskflow/examples/graph_flow.py sha256=xPZRt0OiOBpH6ECMQMc7ppXXs2nLH_L1iD7mpgC6Iag 3461
taskflow/examples/hello_world.py sha256=7xERr8ZnCkvuhOq7aR4vddUFauIofgKh0iecIabzJbE 4216
taskflow/examples/jobboard_produce_consume_colors.py sha256=HG6A-IbIPrYiTDEwyFxD9afDLEcjjmm1iYSrmjFut0c 6821
taskflow/examples/parallel_table_multiply.py sha256=RxuEOb_IddPox0M-5PAMn3L01XscC_vqfN69XUCyeS8 4276
taskflow/examples/persistence_example.py sha256=l-Ap52yOslFfcmfHDKc7kUfrvy4IcL28TjVmOwP4GsU 3906
taskflow/examples/pseudo_scoping.out.txt sha256=ktR2-fVrRo5AsYPRMEBN6KJZ6_0ZMnts29bgN7t42tY 238
taskflow/examples/pseudo_scoping.py sha256=8sNU3ysk6mo7iTsae3WZKhQKI3fAg4mo0Xo6WHZIozA 3497
taskflow/examples/resume_from_backend.out.txt sha256=0THjgMno9e6k3c8l_MTwKWDiQ9Pp2VG19vWjzR2SzFU 678
taskflow/examples/resume_from_backend.py sha256=hroqTvUOfTOVa0OoOz7nL8kmvG_APrsXPSsB4OpT3Fk 4992
taskflow/examples/resume_many_flows.out.txt sha256=laNlJonlvUlDG4zGK_KHZl7GLnJ9w0epaadrKKLns2w 774
taskflow/examples/resume_many_flows.py sha256=ebUbtwJS3HwdRnuqqw_4NxhsZwa6dc6IMZIMxRjwLak 3192
taskflow/examples/resume_vm_boot.py sha256=sJJxJi8I9BdrdhIRnk9Gm_fBNxeRyWkEX4heIqq8buM 9636
taskflow/examples/resume_volume_create.py sha256=RxhHMzN2qfZfaG-Qb_ZIIgAncMj0IKF6xf3qrU5OMoM 5889
taskflow/examples/retry_flow.out.txt sha256=AtZEJMLGSZbHYt1dAB7qcz8s5yrQqigjxc708wvtqmI 116
taskflow/examples/retry_flow.py sha256=PZhcZoNwe8W9aJbRdDpVvT1Hu9m1gTpQy2xcnbKYhPQ 2268
taskflow/examples/reverting_linear.out.txt sha256=MzzbYDNBnyOlvGN_X2A7QEuSyBgYov_Miv-UBDwq9_E 132
taskflow/examples/reverting_linear.py sha256=-kisBKuntdZmt4gQ2Q4XBTxocRIc_3cdrASI4qNGARw 3543
taskflow/examples/run_by_iter.out.txt sha256=xKLg52D8UJZlRboEGCOk83neNYWtpq8SjAwqaRS68fU 823
taskflow/examples/run_by_iter.py sha256=_CmAHoNLIm6AqQ_LPr4WBTrGUgOeyH5nKJt1TKXK9xY 2620
taskflow/examples/run_by_iter_enumerate.out.txt sha256=d5__O4xsSBkO6l4BFK7hK1i97rB1GjhVD-379sIYlaE 849
taskflow/examples/run_by_iter_enumerate.py sha256=SfeeF8_9K_WZj2LMyO0rC5X_95Lg6LxU3Mzc2VS-aRQ 1720
taskflow/examples/share_engine_thread.py sha256=cgZYoJIbxp1zUU42cj5njs3PGJ1FiQwZoE4tnz0JNl4 2742
taskflow/examples/simple_linear.out.txt sha256=F4IDqbYYRPLLzYNXI3teAtgRfOqsAXQKTLY3fArFPoY 34
taskflow/examples/simple_linear.py sha256=V_V6ZhWKoqIqlOeHWwj0HqmuOqFDzOgK5c63CI6zV-M 2507
taskflow/examples/simple_linear_listening.out.txt sha256=1CEQbmwwmBe-YyWVGjjl17Elf70ZOLP9lqn-6Uj7Akk 300
taskflow/examples/simple_linear_listening.py sha256=47NCXWDsXyK6jtloJtAo4iJeVRsYiMvrs2UKjZjkr3E 3958
taskflow/examples/simple_linear_pass.out.txt sha256=Y4GkdMkyoqcwpR98MzRITGVsFRb0mtqbfJ4m2uNvuW4 114
taskflow/examples/simple_linear_pass.py sha256=zVQVR2KFZ_o9_25ii_gFgadMZ2hpEZ8Nmlpxh0Ub4Zs 1792
taskflow/examples/simple_map_reduce.py sha256=YYdGOGQtCgCPW4E6Wzy9NP5fEqfgD_ggcokvdFbe4Zs 3762
taskflow/examples/switch_graph_flow.py sha256=BIJXcz_6BdSR7xZ4s6fD5FmykaMpYGCcUzVs6Oy_42c 1904
taskflow/examples/timing_listener.py sha256=W6SKIOfImdUIrZfpjUgWu2vqC6vgRA8Ux8RKGKM-ScM 2034
taskflow/examples/tox_conductor.py sha256=0VpgXvsDNdRYQy8UJoOSy75Yz7HsYHftcWqdwZebyB4 8472
taskflow/examples/wbe_event_sender.py sha256=F0XJPf0VXtQQl1SML_5XaVE6d2NTNnorVDAR1XG1wPY 5547
taskflow/examples/wbe_mandelbrot.out.txt sha256=fdzWLYHe7PZPGF_RDQ1ty_IdzWSDTZVkpSawjlPlBVM 243
taskflow/examples/wbe_mandelbrot.py sha256=uSpRDOnN15Juyt5h09nvDgdmt7Na08tslMthUKbokvA 8842
taskflow/examples/wbe_simple_linear.out.txt sha256=w8vFgEkV3pBOAKNUPSJkufpTCwXr-ZvGwEjHbx6Q2cg 148
taskflow/examples/wbe_simple_linear.py sha256=dzwjWW6N29aDaipoeSzOoZEvLerf1NN7ngsy_k1Oku0 5413
taskflow/examples/wrapped_exception.py sha256=1rKO_UuvU9R0PgpiSAjdF_eeoFPH51iEEDB7LoHVUNE 4732
taskflow/examples/resume_many_flows/my_flows.py sha256=-cIktLf44U_Nnztezqzt1LsdmIpcO-BaqZYaoSHxev4 1288
taskflow/examples/resume_many_flows/resume_all.py sha256=MahlJx7a3LBh4V7aRu5n5G1qDivqMgcjxOm6KNKycVk 1729
taskflow/examples/resume_many_flows/run_flow.py sha256=MOD78Zg7IaSAVRoLPap36njTZWbHzdxz28fMaHUA_EU 1433
taskflow/jobs/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
taskflow/jobs/base.py sha256=nowX7pKESnTz-_iPmg1vUQJ0bgO3HLOOtytOKOy12kA 22463
taskflow/jobs/backends/__init__.py sha256=ILlqq_U0FPM77nPQgx_OexjHxUvC5Tl4RXkX-IznSfw 2902
taskflow/jobs/backends/impl_etcd.py sha256=3o5xBe0UkqPo9b8LYcbHD2L7e5lDlJHjo8VQsyd4iIE 22067
taskflow/jobs/backends/impl_redis.py sha256=ZgxVSlAOncTE089a6c1qjafSIzv8_ekLQKvq1G_n7IE 43925
taskflow/jobs/backends/impl_zookeeper.py sha256=1Noi75aTH0NCx-qlsRExsx-QKBtY5j2PJb6RIi_Cm5o 37644
taskflow/listeners/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
taskflow/listeners/base.py sha256=vhbh4CcTW9iulQCG-A5G0iJDp7-j1m1XALYRewOanik 7391
taskflow/listeners/capturing.py sha256=14wrkVMrlmPm5jTnTTFM0RFv4PuKMIaIEPmYA4Ki4TA 4329
taskflow/listeners/claims.py sha256=OVmh8xixuohxuYY6A0Nfy72GhDNut1cGzsowiMOUyUQ 4115
taskflow/listeners/logging.py sha256=1nIB7MrbCznugN8j9CDPZZgMxCtmqzlj1LOIxiDHLNA 8516
taskflow/listeners/printing.py sha256=OxLZSHKFuhO8F0SzsnXCAJrfIsNlu-VK_TWJWcug2Tg 1675
taskflow/listeners/timing.py sha256=Gq8BLTpIqFXPRxh9RCzIRJcA4lDFSAWwlXwCqwGWZ98 6943
taskflow/patterns/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
taskflow/patterns/graph_flow.py sha256=9AR9UAjv7uAUE9JfZZvZWvZIpLAwDl2Q-nCn6ASFYWY 15292
taskflow/patterns/linear_flow.py sha256=DZ3bAzrZJ2Zf3hRqRLpoNXi9qeUDMzJo7d0sV7Hb9Zk 2804
taskflow/patterns/unordered_flow.py sha256=Okei5mSYAHSzLOZMtHynC1vBFgY7O9E6Zloi2_pEaUE 2055
taskflow/persistence/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
taskflow/persistence/base.py sha256=QfDV1WKBvCYHbRga_gKKUzicsHxqpsTU2tU7YjxUkLU 4072
taskflow/persistence/models.py sha256=GTT4n75y5-imTYPEWTelwSYV6IidewObU_S_AnwUP7E 40762
taskflow/persistence/path_based.py sha256=0d4I9HgTdAhJarxEJkRiZNNxC-M2tbQebeDLby8PCwI 9545
taskflow/persistence/backends/__init__.py sha256=z5k5CZNjtbKvj2uxqNrdPmREDUGlTMrthcC723gPnsg 3352
taskflow/persistence/backends/impl_dir.py sha256=t8YQe4llF4ghguTh45BBEzRvvtpCllaAbuFZhOY_4os 6085
taskflow/persistence/backends/impl_memory.py sha256=PHKHqeV_KkkwCpT42J2j22o8gfdjAKt3recCP6k5TUw 13390
taskflow/persistence/backends/impl_sqlalchemy.py sha256=4YJp88fb2rfDw6Pxrnfebxpo1DhtY_fu8q_8BEnuwWk 25540
taskflow/persistence/backends/impl_zookeeper.py sha256=PaJmf-xDk7udmYzrMxRM-ARrd1HfAucqQjYIljmpixM 6188
taskflow/persistence/backends/sqlalchemy/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
taskflow/persistence/backends/sqlalchemy/migration.py sha256=YS4UPcygmYV1lRTogPUuyMM39DupIZ1LwuD23yoaEno 1140
taskflow/persistence/backends/sqlalchemy/tables.py sha256=CUHMWfVIK9bim-APx4QSmFuru1FyJIrOFl7hT51dQcs 4819
taskflow/persistence/backends/sqlalchemy/alembic/README sha256=K6farsrYU2S5Gb1nrz5I64Okvqu9LjOPTqXlBzvUitU 411
taskflow/persistence/backends/sqlalchemy/alembic/alembic.ini sha256=9Tb5IRu220Gl3gARRXRw0jL5Caql4JNjF1C-VUenEvI 420
taskflow/persistence/backends/sqlalchemy/alembic/env.py sha256=MLhIBeDXnJsA1xy112o87jsQnFQyIu-MctJvzMt1mrU 2683
taskflow/persistence/backends/sqlalchemy/alembic/script.py.mako sha256=D8kFI44_9vBJZrAYSkZxDTX2-S5Y-oEetEd9BKlo9S8 412
taskflow/persistence/backends/sqlalchemy/alembic/versions/0bc3e1a3c135_set_result_meduimtext_type.py sha256=3AM6AyxwC4seS5lo_XKixPxdw1XJB4ly5Og9WXnZ-FM 1315
taskflow/persistence/backends/sqlalchemy/alembic/versions/14b227d79a87_add_intention_column.py sha256=vFasN2Ug7J14HcHlOBmSQ6ssSpC3xqsbc2rqXPPIEVM 1255
taskflow/persistence/backends/sqlalchemy/alembic/versions/1c783c0c2875_replace_exception_an.py sha256=Nwd1QEjnu8A8ENlT-W8-mt9WEDHBXb8C4BFuF1vEDS4 1437
taskflow/persistence/backends/sqlalchemy/alembic/versions/1cea328f0f65_initial_logbook_deta.py sha256=ggibdDgBCqLXFyoYJKWAJ7uFxccFt8wOikiAXo6vW2E 5459
taskflow/persistence/backends/sqlalchemy/alembic/versions/2ad4984f2864_switch_postgres_to_json_native.py sha256=NDeudKpMs8iPQjnEYYSwZPXNDuBpG_FVkRTqT3RJlXs 1778
taskflow/persistence/backends/sqlalchemy/alembic/versions/3162c0f3f8e4_add_revert_results_and_revert_failure_.py sha256=-36Wzj6Vs5kkn1rUrYwYn38gay0uH3FLBjUfBsgPJqI 1315
taskflow/persistence/backends/sqlalchemy/alembic/versions/40fc8c914bd2_fix_atomdetails_failure_size.py sha256=yitIJ9n6B-_NHillKV3nhP6UX8bhrl0byM1-wphdj-Q 1205
taskflow/persistence/backends/sqlalchemy/alembic/versions/589dccdf2b6e_rename_taskdetails_to_atomdetails.py sha256=yZG_KcQEHJAkqQPypmFY2jiGIee2bS3yScLNgyxhpBU 1047
taskflow/persistence/backends/sqlalchemy/alembic/versions/6df9422fcb43_fix_flowdetails_meta_size.py sha256=C6I4HCGnmsjy5iVD2s98-ydWYL3nW25Ng1MaJ0svt4I 1072
taskflow/persistence/backends/sqlalchemy/alembic/versions/84d6e888850_add_task_detail_type.py sha256=PG7eTGhTsmUbnD02Pyn-SQqC5f7544cYdTtvnnE0xBA 1315
taskflow/persistence/backends/sqlalchemy/alembic/versions/README sha256=AwegmiWc0MVoYyckyRzPFV4kVZqs8Q4w6eeMm0K3I_o 38
taskflow/tests/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
taskflow/tests/fixtures.py sha256=VfGlusX2q79_ktPME4cm1qt_gN9VNRAwyYy5sDBAX0Y 2004
taskflow/tests/test_examples.py sha256=g2zhguLKE4Tex2e_vSmKMhsNXItnKWj89_VbnmgGejU 4925
taskflow/tests/utils.py sha256=go8D7cUHQJ31F0n0Ts5ijeHdC7JsCFpsgdHb09QL5A4 11954
taskflow/tests/unit/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
taskflow/tests/unit/test_arguments_passing.py sha256=jK9-Z7xBfPI4nHB7_Bh_rllBH-X55v6wplxdrjwRS3E 9381
taskflow/tests/unit/test_check_transition.py sha256=DuxJAErCwheWPAdN_43LOOvZg00vmUoC-IzGgh642IM 6173
taskflow/tests/unit/test_conductors.py sha256=-TEP_8ap69bPHhEabx2Dk8qNJuI_kBNCSuPcGcvZl2w 18996
taskflow/tests/unit/test_deciders.py sha256=I5nDijs0Ybhw0HmCjY41N2L612U03-xH9Z7COWEaWy4 2733
taskflow/tests/unit/test_engine_helpers.py sha256=EPYzq1r5d3cvIxseBeTLGPY3ZkJtV7C6Zi8il-cO94o 5399
taskflow/tests/unit/test_engines.py sha256=30MZKR3hALtZk2CbY85T2iBIQOOWN-ZigPR6yYFd748 64570
taskflow/tests/unit/test_exceptions.py sha256=QDpa7X99Z5ET7s0dimV_YY4wit8Oqrcs5fZG7fTmX2Q 4362
taskflow/tests/unit/test_failure.py sha256=xnmkeSuQlTCCsXL6PvgAkQrPN28ahESQL2sEftwyuKQ 17982
taskflow/tests/unit/test_flow_dependencies.py sha256=PGPjxp-VeVp1E2Of6OAnEsyB0p4xTa-xd7NLnyjtl-A 18086
taskflow/tests/unit/test_formatters.py sha256=vSwbBbPmuET18Sc-3p1kCIHdb9g2F4RHxANXEJHzWQA 3921
taskflow/tests/unit/test_functor_task.py sha256=gAjJE2urR61-pFd98mtmAkSKYX2vPwp17ied3LjhdNQ 2528
taskflow/tests/unit/test_listeners.py sha256=3VZo4cNG0HYRuatqBezbNdXD99bLjgSiCdbD67SIu-A 15304
taskflow/tests/unit/test_mapfunctor_task.py sha256=1FI8AJxRUPxT7Lu6h9Mhd62srAnKfC2ETvGqA2772sM 2368
taskflow/tests/unit/test_notifier.py sha256=Q4xGl9e_LZRiJVpGR2FbG2qSp9CqlP65aDsaIKxPqHI 7894
taskflow/tests/unit/test_progress.py sha256=oeYFeWuHde1D2cAahhE1yN1NznNcXk7ajw0Z2yCyZkM 5259
taskflow/tests/unit/test_reducefunctor_task.py sha256=vM4P5h80-Ex4uq2N_dNmTFL49Ks3iFmP5dMbZEk0YQ0 2106
taskflow/tests/unit/test_retries.py sha256=xxHEBNoiaDR5WMztzm5CidqGrOkKJ2yqs2J69P1KwkE 58658
taskflow/tests/unit/test_states.py sha256=iYyHo9YzHBMjlYaqlzZJTcKjB53WCqf5Fw3OGoVKVME 3660
taskflow/tests/unit/test_storage.py sha256=SlShgJ4hirdnggDkpB3GoosY--4B0PqMOVvMBG5D6g4 23520
taskflow/tests/unit/test_suspend.py sha256=2d5y15Fw6NESJ4oEUAA7dosECGb2-CLkkgXULqwNtWw 10077
taskflow/tests/unit/test_task.py sha256=PGXlOIhpYdCo8hTScleIHxQ5gGa-1b1MJhwaiB_fQss 15947
taskflow/tests/unit/test_types.py sha256=uecv0lBqPAfAdTDXYMoM8Pi-P9JROR-aA_xkK0trJSQ 20225
taskflow/tests/unit/test_utils.py sha256=m5Wct0kqv8CoX03sUBXcVczAuGcF-AQtbYPxUDq64oo 11035
taskflow/tests/unit/test_utils_async_utils.py sha256=BkVaxbRO3XX2ueAy6kSplq4D1SVos8DOaf9V1mueEf4 981
taskflow/tests/unit/test_utils_binary.py sha256=OdF2BIeUCIP4hXi6QsYv8IqZtDpmqCZySlv5nLZ6UOk 3168
taskflow/tests/unit/test_utils_iter_utils.py sha256=jzUJzUtfL1EPRoQLoUzZ0chlkuTKoqQKHjz7F-LaZ3Y 5716
taskflow/tests/unit/test_utils_kazoo_utils.py sha256=lYV5ust99XF-ExaPaZ6_laPSJDewT6cTrBWw9X13nGw 1963
taskflow/tests/unit/test_utils_threading_utils.py sha256=JxWTMFQwjUXmsEBKl6c207VPpZn3Wh_lY3MYH-iEFUA 5503
taskflow/tests/unit/action_engine/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
taskflow/tests/unit/action_engine/test_builder.py sha256=tuL4LoPpnvqnGBE9qAoVXVHLzARGwhhOu4q1cSnvZ68 12866
taskflow/tests/unit/action_engine/test_compile.py sha256=dFaYxLiaCCoMY9TsrsQgN_wfwuu8rvWCW6hwABWlIbU 23759
taskflow/tests/unit/action_engine/test_creation.py sha256=By8RzbkFI2uyQnU66n5Ul1-1XIJo7x7ybcx5Ln5iYWs 3681
taskflow/tests/unit/action_engine/test_process_executor.py sha256=WDqA_zv1tsS2bPN7lCqwE6avgjAlO8D0_znnF9jhUAQ 3613
taskflow/tests/unit/action_engine/test_scoping.py sha256=wIB9C3LMgfsqO6cdz_ZdhQcjrOFWAFn-9F6rEMjizgM 11327
taskflow/tests/unit/jobs/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
taskflow/tests/unit/jobs/base.py sha256=wYv5ziDeVdYn2nhuMSfYTWU39Xxpv8lRKvJbGsB79lM 8447
taskflow/tests/unit/jobs/test_entrypoint.py sha256=t2m5zeYhjb2pmPxBgGO_0AMWR0dabWxglDBODzLE0fY 2220
taskflow/tests/unit/jobs/test_etcd_job.py sha256=oKnZ0nnmpmr9K04x3a4d6STvrE811uPRYdrJAbgdyv0 16512
taskflow/tests/unit/jobs/test_redis_job.py sha256=wHwptqgrafZMk0aDZNvn2h3sJw8ckKY1g5J9I_dzWAM 7394
taskflow/tests/unit/jobs/test_zk_job.py sha256=e5CdkqmiQY_jzNtcHsxKcsS9uY7k-D8CMGkqt1J_bqE 13789
taskflow/tests/unit/patterns/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
taskflow/tests/unit/patterns/test_graph_flow.py sha256=g5x6RdEgD6Sws3C5zmgz3kFpbJLEoi6i42RSEk5Vlso 12452
taskflow/tests/unit/patterns/test_linear_flow.py sha256=jSgrxvCk-Ovly1NZSVY04pCRDjzWtkESQf--PuZbH6E 5133
taskflow/tests/unit/patterns/test_unordered_flow.py sha256=kN4o_0pP4losZVba0uDtJvHZwJb8pMUyVRP8cCz__1g 4981
taskflow/tests/unit/persistence/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
taskflow/tests/unit/persistence/base.py sha256=Pot7g2ceqHuw-EmuYTm2SS0iQi1yruHgp-zM-pTQ6l8 16547
taskflow/tests/unit/persistence/test_dir_persistence.py sha256=hHfTy_KckkW95PA-gfk17kO8kQtNh1_62UNWeXpec2M 3929
taskflow/tests/unit/persistence/test_memory_persistence.py sha256=Kojaw3nX0RZrU2yPZ_FjZGQ4p5AA-VAPh6gxs48VVz8 7871
taskflow/tests/unit/persistence/test_sql_persistence.py sha256=jchWNZkLEDAkw5wFvdTHeAAUGPsJtxpsnp8Qp8zQAv0 10260
taskflow/tests/unit/persistence/test_zk_persistence.py sha256=ilj1vtTgN6_VtJV13ueYvK657jHvcwXgHcQ8pH76R3g 3648
taskflow/tests/unit/worker_based/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
taskflow/tests/unit/worker_based/test_creation.py sha256=r7DV1NfgF3Ulw3DOhX8L6lZ0poDjo6nwexhAzXPq9Vc 4045
taskflow/tests/unit/worker_based/test_dispatcher.py sha256=TOqdvpGIvG7JA1IpioVwxq7jIvbMU3MC9CEnhq29SkE 2915
taskflow/tests/unit/worker_based/test_endpoint.py sha256=G0T1CK0xkSqAMqotvkLvx4HO5dHa6XFjxDD5VtrQ1d8 3128
taskflow/tests/unit/worker_based/test_executor.py sha256=l-KArQioziEaWymbAVBzWcCp5ZoqysLpNgUm1DTI9f8 13622
taskflow/tests/unit/worker_based/test_message_pump.py sha256=MXMr6yPoEUxpmcAmRD0-_Y-Ndh0jZU9OkOWv9ceHRZk 4894
taskflow/tests/unit/worker_based/test_pipeline.py sha256=b9bDyy03TNdUTPR39gtGo5tJu-qMSJQq1jMuyRCKXxw 3812
taskflow/tests/unit/worker_based/test_protocol.py sha256=8FTuPszt1Njp-uuuLI5FEuwOOw_UjYzvtRIYMlWfbLA 7745
taskflow/tests/unit/worker_based/test_proxy.py sha256=MlnTEqfUypGrmzWBY3vXYF5-K6brGUoozXdTjKOIvAc 9920
taskflow/tests/unit/worker_based/test_server.py sha256=GasvLzOWUN5T_1o8sJTfaKFICSet-dh8G_jXlOoa7wA 14344
taskflow/tests/unit/worker_based/test_types.py sha256=EXKG4ihOrQqKCzo7NQwRlk1peXku8OjGJy1B4GLNOFU 3368
taskflow/tests/unit/worker_based/test_worker.py sha256=1jmGrtL6atPu88zBRTMOe1pUlUFAZzuXwM7sQxIX2lY 7109
taskflow/types/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
taskflow/types/entity.py sha256=vIPHHNnA7givgPh-vOIzSEP3Hu9baRwl1fQXtAJ9y-g 1587
taskflow/types/failure.py sha256=4Jn5oH5QG6392kEYp_Exu2SnNDh2Ydg89ST1w4cB1Fw 21189
taskflow/types/graph.py sha256=T0JbyYfHVtNlzQW_ATuQngc7e-WpVS7NMnOFpJY6xSc 10504
taskflow/types/latch.py sha256=ZYE7qQeyTaKK9ChIVJx7Y0U0iBBjsuVU_-kpwIWd_-w 2193
taskflow/types/notifier.py sha256=2N_GqBcseYPD9DSsBKRCgvuuSvCMZYj7MN-oPcYDmc4 14071
taskflow/types/sets.py sha256=FFdJv4S0C5_1-xi_lsg6rzMZTNEgI7rbtEzMTZOREI0 4004
taskflow/types/timing.py sha256=TR4FrQnZivEiUJ0r5Z6iiVFvXZbexMo20gfoOHGxr0I 2313
taskflow/types/tree.py sha256=j-5i3haMJ259ATNI4EccQjhg60_0mXHStIvOgKFM-LE 15820
taskflow/utils/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
taskflow/utils/async_utils.py sha256=aoRp7cY8cm5jSsOy3RyV5Fjr27U2J_V6ldMYVWTPJJ4 855
taskflow/utils/banner.py sha256=_44ZM33gye8orjUN4B_VdQe8ksEPAK3WI6pfrMMiEiE 3635
taskflow/utils/eventlet_utils.py sha256=-0Tpw9x8UmQYXbyCbh751k1D5gPYVQv2zqCRis3vcmE 1149
taskflow/utils/iter_utils.py sha256=RAMpEe7pYsXXoObke0Jh2ePpfdX7cTDxhTgHua2v37M 4674
taskflow/utils/kazoo_utils.py sha256=fCHMC-a5ayJqzBVjdTiy1WqBE6hSmRwxx7GkF-jd6Nw 9915
taskflow/utils/kombu_utils.py sha256=tgAN6c7kSggbT0rMn3rVzkKm9e1CmW90Jpb5279G2zg 2528
taskflow/utils/misc.py sha256=yHfRx6P0TqADiL-f-m5H74ugG2U7p5ktYkMK9DVGdWA 18504
taskflow/utils/persistence_utils.py sha256=GWceOcxdfsf-MtrdR74xmC2khClF8im6DpZmR2UpYuU 3899
taskflow/utils/redis_utils.py sha256=zJBvXmlNZUQ_gwGZAaNLySVtCtou3YayHAkGSCNKDUw 4345
taskflow/utils/schema_utils.py sha256=Zf6eL0NK0_TVFD_Sc1yEZYswFz9K0tet1Dmj48F8uMA 1434
taskflow/utils/threading_utils.py sha256=eiaNUK127DOBr_zfj3-j4Oi5a2dsD7VunVeTYN6NjPo 5849
taskflow-5.10.0.dist-info/AUTHORS sha256=uKVGnRq9UrIKLl5MhXJ9QuqzKXynjWcZcuaW_j9Eh5g 4564
taskflow-5.10.0.dist-info/LICENSE sha256=0t4vVm0tDgtQn7DqH6Nmn0kGSrHeIcV0U8qzdQojTo8 10143
taskflow-5.10.0.dist-info/METADATA sha256=00c6g5TTpnnUNoUfegIhFOcW3UNe6AUwJJeffNiW56o 5148
taskflow-5.10.0.dist-info/WHEEL sha256=g4nMs7d-Xl9-xC9XovUrsDHGXt-FT0E17Yqo92DEfvY 92
taskflow-5.10.0.dist-info/entry_points.txt sha256=bIwgsxgCx_nrcv_gMhFDVffkg_r4NHX2O43iEXUKohU 1236
taskflow-5.10.0.dist-info/pbr.json sha256=MnKpu3FknIa1gymaX8zBrpnFmCgZhaJSO_Uv-oBZvJQ 47
taskflow-5.10.0.dist-info/top_level.txt sha256=PsdN41vwysesDlqHCSVVXH4mkTMdMiZFW_yHEAXiZE4 9
taskflow-5.10.0.dist-info/RECORD — —

top_level.txt

taskflow

entry_points.txt

[taskflow.conductors]
blocking = taskflow.conductors.backends.impl_blocking:BlockingConductor
nonblocking = taskflow.conductors.backends.impl_nonblocking:NonBlockingConductor
[taskflow.engines]
default = taskflow.engines.action_engine.engine:SerialActionEngine
parallel = taskflow.engines.action_engine.engine:ParallelActionEngine
serial = taskflow.engines.action_engine.engine:SerialActionEngine
worker-based = taskflow.engines.worker_based.engine:WorkerBasedActionEngine
workers = taskflow.engines.worker_based.engine:WorkerBasedActionEngine
[taskflow.jobboards]
etcd = taskflow.jobs.backends.impl_etcd:EtcdJobBoard
redis = taskflow.jobs.backends.impl_redis:RedisJobBoard
zookeeper = taskflow.jobs.backends.impl_zookeeper:ZookeeperJobBoard
[taskflow.persistence]
dir = taskflow.persistence.backends.impl_dir:DirBackend
file = taskflow.persistence.backends.impl_dir:DirBackend
memory = taskflow.persistence.backends.impl_memory:MemoryBackend
mysql = taskflow.persistence.backends.impl_sqlalchemy:SQLAlchemyBackend
postgresql = taskflow.persistence.backends.impl_sqlalchemy:SQLAlchemyBackend
sqlite = taskflow.persistence.backends.impl_sqlalchemy:SQLAlchemyBackend
zookeeper = taskflow.persistence.backends.impl_zookeeper:ZkBackend