"""ASF Worker job handlers — pluggable async handlers called from the generic consumer loop. New capabilities are registered in ``REGISTRY`` below: mapping of ``job_type`` string to a ``JobHandlerFn``. The worker will route incoming messages by matching ``JobRequestEnvelope.job_type`` against keys in ``REGISTRY``. Currently stubbed; individual handler modules are added incrementally as features are plugged in (see bootstrap prompt §16). """ from __future__ import annotations from asf_events.base import JobRequestEnvelope from ..handlers import HandlerResult, WorkerDependencies from ..worker import JobHandlerFn REGISTRY: dict[str, JobHandlerFn] = { # "ai.analyze_code": run_analyze_code, # "ai.generate_tests": run_generate_tests, # "ai.decompose_requirements": run_decompose_requirements, }