.flake8
.gitignore
LICENSE
Makefile
README.md
conftest.py
dispatcher.yml
docker-compose.yml
pyproject.toml
requirements_dev.txt
run_demo.py
schema.json
sonar-project.properties
.github/CODEOWNERS
.github/ISSUE_TEMPLATE/bug_report.yml
.github/ISSUE_TEMPLATE/config.yml
.github/ISSUE_TEMPLATE/feature_request.yml
.github/workflows/ci.yml
.github/workflows/release.yml
.github/workflows/sonarcloud.yml
asyncio_tests/__init__.py
asyncio_tests/integration/__init__.py
asyncio_tests/integration/conftest.py
asyncio_tests/integration/test_bind.py
asyncio_tests/integration/test_callable_queues.py
asyncio_tests/integration/test_disruptions.py
asyncio_tests/integration/test_main.py
asyncio_tests/integration/test_metrics_use.py
asyncio_tests/integration/test_pool.py
asyncio_tests/integration/test_producers.py
asyncio_tests/integration/test_signal_handling.py
asyncio_tests/integration/test_socket_use.py
asyncio_tests/integration/test_worker_callbacks.py
asyncio_tests/integration/test_worker_signals.py
asyncio_tests/integration/brokers/__init__.py
asyncio_tests/integration/brokers/test_pg_notify.py
asyncio_tests/integration/brokers/test_socket.py
asyncio_tests/unit/__init__.py
asyncio_tests/unit/test_broker_callbacks.py
asyncio_tests/unit/test_chunking.py
asyncio_tests/unit/test_connection_saver.py
asyncio_tests/unit/test_control_cleanup.py
asyncio_tests/unit/test_next_wakeup_runner_errors.py
asyncio_tests/unit/service/__init__.py
asyncio_tests/unit/service/conftest.py
asyncio_tests/unit/service/test_asyncio_tasks.py
asyncio_tests/unit/service/test_blocker.py
asyncio_tests/unit/service/test_chunk_cleanup.py
asyncio_tests/unit/service/test_control_tasks_unit.py
asyncio_tests/unit/service/test_main.py
asyncio_tests/unit/service/test_metrics.py
asyncio_tests/unit/service/test_next_wakeup_runner.py
asyncio_tests/unit/service/test_pool.py
asyncio_tests/unit/service/test_pool_scaledown.py
asyncio_tests/unit/service/test_process.py
asyncio_tests/unit/service/test_worker_liveness.py
asyncio_tests/unit/service/test_worker_order.py
asyncio_tests/unit/service/test_worker_retirement.py
dispatcherd/__init__.py
dispatcherd/chunking.py
dispatcherd/cli.py
dispatcherd/config.py
dispatcherd/control.py
dispatcherd/factories.py
dispatcherd/protocols.py
dispatcherd/publish.py
dispatcherd/registry.py
dispatcherd/utils.py
dispatcherd.egg-info/PKG-INFO
dispatcherd.egg-info/SOURCES.txt
dispatcherd.egg-info/dependency_links.txt
dispatcherd.egg-info/entry_points.txt
dispatcherd.egg-info/requires.txt
dispatcherd.egg-info/top_level.txt
dispatcherd/brokers/__init__.py
dispatcherd/brokers/pg_notify.py
dispatcherd/brokers/socket.py
dispatcherd/processors/blocker.py
dispatcherd/processors/delayer.py
dispatcherd/processors/params.py
dispatcherd/processors/queuer.py
dispatcherd/producers/__init__.py
dispatcherd/producers/base.py
dispatcherd/producers/brokered.py
dispatcherd/producers/control.py
dispatcherd/producers/on_start.py
dispatcherd/producers/scheduled.py
dispatcherd/service/asyncio_tasks.py
dispatcherd/service/control_tasks.py
dispatcherd/service/main.py
dispatcherd/service/metrics.py
dispatcherd/service/next_wakeup_runner.py
dispatcherd/service/pool.py
dispatcherd/service/process.py
dispatcherd/testing/__init__.py
dispatcherd/testing/asyncio.py
dispatcherd/testing/producers.py
dispatcherd/testing/subprocess.py
dispatcherd/testing/brokers/__init__.py
dispatcherd/testing/brokers/error_only.py
dispatcherd/testing/brokers/memory.py
dispatcherd/testing/brokers/noop.py
dispatcherd/worker/exceptions.py
dispatcherd/worker/target.py
dispatcherd/worker/task.py
docs/config.md
docs/contributing.md
docs/design_notes.md
docs/message_formats.md
docs/signal_guidance.md
docs/submit_task.md
docs/task_options.md
docs/worker_statuses.md
logs/.gitignore
tests/__init__.py
tests/benchmark/__init__.py
tests/data/__init__.py
tests/data/callbacks.py
tests/data/methods.py
tests/data/signal_tasks.py
tests/data/nested/methods.py
tests/data/nested/nested_registry.py
tests/integration/__init__.py
tests/integration/test_control_tasks.py
tests/integration/publish/__init__.py
tests/integration/publish/test_registry.py
tests/testing/test_debug_brokers.py
tests/unit/test_chunking.py
tests/unit/test_cli_control_args.py
tests/unit/test_config.py
tests/unit/test_connection_saver.py
tests/unit/test_control_cleanup.py
tests/unit/test_control_tasks.py
tests/unit/test_factories.py
tests/unit/test_pg_notify_self_check.py
tests/unit/test_publish.py
tests/unit/test_registry.py
tests/unit/test_utils.py
tests/unit/utils.py
tests/unit/processors/test_params.py
tests/unit/service/test_dispatcher_recycles.py
tests/unit/service/test_process.py
tests/unit/service/test_usage_tracker.py
tests/unit/service/producers/test_scheduled_producer.py
tests/unit/worker/test_signals.py
tests/unit/worker/test_target.py
tests/unit/worker/test_task_worker.py
tools/gen_schema.py
tools/demo/Dockerfile