dispatcherd/__init__.py,sha256=vKhMMzmxEmYBhFgYlnooGtEn5JlgaCCsjCWZBVcSiCU,603
dispatcherd/chunking.py,sha256=gYJRaephMh456PQmprX-C29kjH_QKmg-SgY5CX-9D0A,13013
dispatcherd/cli.py,sha256=PENpCLpsdpGouMyc8Aj2QbNW10rKJBdroM_JCfLHDm4,6079
dispatcherd/config.py,sha256=t-9j4X8oHtF7SHMH5KGk6GtrZ1cWDrP0EM4q5EiusX4,2473
dispatcherd/control.py,sha256=gweuP2lM5BA-MPdMK95X9ovvxLH8SBkJLP_FOwBagsk,8295
dispatcherd/factories.py,sha256=fKB8KuCUCbpNHU_rCPo6O33d4ACQVgjLSA4aMeaKrTk,7733
dispatcherd/protocols.py,sha256=kQgDbe3aWB-xqUGVfDPSoVb5BrJcSCwjnmNse2BHlsg,10718
dispatcherd/publish.py,sha256=XxXCT72D9YNgMiZLyp9BLB_Nq912jA54bBKXVrpWNTg,5890
dispatcherd/registry.py,sha256=yereXuncyUArq-xBLU2EtSPBuvL-DIiaBEk0EhRIAug,7703
dispatcherd/utils.py,sha256=-FKfxWhARbVCMH3W_pXYpxatVEzflY5HqoG4bNURrDU,1665
dispatcherd/brokers/__init__.py,sha256=7zLH0HoAyZpOdxDt0h6RoYBAsLu0NNfjYG8kAwU503s,1061
dispatcherd/brokers/pg_notify.py,sha256=WRpYi80HURWT41pLZ6YTSfNMweknSQdldcKwHy6OIB0,21783
dispatcherd/brokers/socket.py,sha256=1TE3CV4x0j4WUtsVUt0mDu7F6Vu-1gWpFexn3l0dZcM,9698
dispatcherd/processors/blocker.py,sha256=jMrmKwkaisNcZX1ZRLwN-7QKrEyGV9y9nFCB82DptMQ,4234
dispatcherd/processors/delayer.py,sha256=-vt9Jkpy7-gcNCS47bfg92bLNYZx8zHbaoStV2jZsjM,3798
dispatcherd/processors/params.py,sha256=t0Qmds_RXViA2rRFWjoxL-y_qK88vsNOS1wKRNvYSsw,753
dispatcherd/processors/queuer.py,sha256=D2-lSNzHUezzqgObUHUiG6uYtNByZX4VJ9s1hllGjZY,2523
dispatcherd/producers/__init__.py,sha256=SY6XC8iRkTpI3PYk00QhYbQKdf-YIqB5GWbN6rEOZuk,293
dispatcherd/producers/base.py,sha256=xQ34RwWI1Ex8kT2-i6EJD6lsFsVlFTWgnmbHWaiH4oQ,783
dispatcherd/producers/brokered.py,sha256=HYuXzwbw1X6mfrS9YfiqxCTDdXQnk7kVz9pTiV9DP8E,3424
dispatcherd/producers/control.py,sha256=zhGPSEJAYqtJZ_cVdhhgDrh-x3wInnVGaAhTb-x57gg,1104
dispatcherd/producers/on_start.py,sha256=CFKJ2c9wPQo1uT6-Pj_ZHp0VD6olqVrjmPAEMa55Ok4,1004
dispatcherd/producers/scheduled.py,sha256=guKj_rBu4-GzFfofrGHJX23BQWEKaR195LBAcIlSXgA,2421
dispatcherd/service/asyncio_tasks.py,sha256=pFerWnUzFKGajQDfW8ZHLMGcGsVX4FJ0o2_5YGI3n0E,3908
dispatcherd/service/control_tasks.py,sha256=fpNw2uildSEPx6jH_7Rnrw7gmLZCRdP1NbfoNKeMuGM,9039
dispatcherd/service/main.py,sha256=SnDNRPzW6CZ-Za6Yw0rEv1UsU-O4mtpLTpaHIbIZuhY,11268
dispatcherd/service/metrics.py,sha256=YHw055XIsODQcaYFkxFDxiEblnx_ZFZH4e6j1yxKx6k,12659
dispatcherd/service/next_wakeup_runner.py,sha256=l1vPGKqs8YjV5pqBypJ9JQXSaNn_Uzy9qiRXlghRUL4,5988
dispatcherd/service/pool.py,sha256=I2nSKxsGLfxYTLhX8yWtzy1M7-Bqzq5Nng7Zn6uleEY,40213
dispatcherd/service/process.py,sha256=LmlcysL0q0O0Cvl3Iopsn7RzIhsmnB5YM463qEh5JXs,5339
dispatcherd/testing/__init__.py,sha256=0v3Fx0SEtRfRP4yGt5yS_mdS9mEipyMDeEBqSFEj7t4,217
dispatcherd/testing/asyncio.py,sha256=Gwhzrm4-GPD-2ezG450pJDZI4e_dHZrrEKEXvuD138A,3814
dispatcherd/testing/producers.py,sha256=KHE0WqtsLnD8seJiJWtsiAnLmcgFzWT_9TpW6Jjcw8E,2626
dispatcherd/testing/subprocess.py,sha256=erGTX8eecx1EP079-SU84BB2cuRDX9g91QpUmuomvvw,6121
dispatcherd/testing/brokers/__init__.py,sha256=ZXAgutltUDH04maF9Mx_1is8DixdHUrDK0IXcWIQ-qY,82
dispatcherd/testing/brokers/error_only.py,sha256=ooymXpT1FWW-xI8sJ49UnIjD57zh3Gy1XXjvrAZjmyc,738
dispatcherd/testing/brokers/memory.py,sha256=CsaZoO06Ti56m66D1HAnUC6gGaE14AhFP5op1dk7mz0,3160
dispatcherd/testing/brokers/noop.py,sha256=ebLAbTBNcp7ksxDaYLHF3d2hG5vwPG5vH45fQayVYjY,2286
dispatcherd/worker/exceptions.py,sha256=bi_520tVxATXjReMetptxYlJVayRQUydl2LwY5Jz-cI,298
dispatcherd/worker/target.py,sha256=FIWfVLEBFF7izsaPqJ61xBO5W3hGA4bYH80lkOy_wss,3409
dispatcherd/worker/task.py,sha256=U9VSUPqE5rz_C9XByansraupS-Zu8zHDGvVJv3BcsBc,10786
dispatcherd-2026.5.27.dist-info/licenses/LICENSE,sha256=z8d0m5b2O9McPEK1xHG_dWgUBT6EfBDz6wA0F7xSPTA,11358
dispatcherd-2026.5.27.dist-info/METADATA,sha256=RLl9Kqq5MSnJhJoZ1Z_qPsP6hkORuRl0N5Nx-E767gQ,9226
dispatcherd-2026.5.27.dist-info/WHEEL,sha256=aeYiig01lYGDzBgS8HxWXOg3uV61G9ijOsup-k9o1sk,91
dispatcherd-2026.5.27.dist-info/entry_points.txt,sha256=XwKlfusAZ47vBy_eM_GnKZdT5fArY7Z-wSoValVmDFA,99
dispatcherd-2026.5.27.dist-info/top_level.txt,sha256=7GWkAzjS1Gc3wn7CWt0HWhaplS3gbx80Qu5InGW-y6w,12
dispatcherd-2026.5.27.dist-info/RECORD,,
