.flake8
.gitignore
LICENSE
Makefile
README.md
dispatcher.yml
docker-compose.yml
mypy.ini
pyproject.toml
requirements_dev.txt
run_demo.py
schema.json
.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
dispatcherd/__init__.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/subprocess.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/submit_task.md
docs/task_options.md
logs/.gitignore
tests/__init__.py
tests/conftest.py
tests/benchmark/__init__.py
tests/data/__init__.py
tests/data/callbacks.py
tests/data/methods.py
tests/data/nested/methods.py
tests/data/nested/nested_registry.py
tests/integration/__init__.py
tests/integration/conftest.py
tests/integration/test_bind.py
tests/integration/test_callable_queues.py
tests/integration/test_control_tasks.py
tests/integration/test_disruptions.py
tests/integration/test_main.py
tests/integration/test_metrics_use.py
tests/integration/test_pool.py
tests/integration/test_producers.py
tests/integration/test_signal_handling.py
tests/integration/test_socket_use.py
tests/integration/test_worker_callbacks.py
tests/integration/brokers/test_pg_notify.py
tests/integration/brokers/test_socket.py
tests/integration/publish/__init__.py
tests/integration/publish/test_registry.py
tests/unit/test_broker_callbacks.py
tests/unit/test_config.py
tests/unit/test_connection_saver.py
tests/unit/test_control_cleanup.py
tests/unit/test_factories.py
tests/unit/test_next_wakeup_runner_errors.py
tests/unit/test_publish.py
tests/unit/test_registry.py
tests/unit/test_utils.py
tests/unit/processors/test_params.py
tests/unit/service/test_asyncio_tasks.py
tests/unit/service/test_blocker.py
tests/unit/service/test_next_wakeup_runner.py
tests/unit/service/test_pool.py
tests/unit/service/test_process.py
tests/unit/service/test_worker_liveness.py
tests/unit/service/producers/test_scheduled_producer.py
tests/unit/worker/test_signals.py
tests/unit/worker/test_task_worker.py
tools/gen_schema.py
tools/demo/Dockerfile