|՞i0dZddlmZmZddlmZmZgdZy)u Genesis Task Queue — Dramatiq-backed async job dispatch with Redis broker. Provides 4 priority queues: - critical : voice/realtime tasks (max_retries=1) - high : customer operations (max_retries=3) - default : background tasks (max_retries=3) - low : analytics/reporting (max_retries=5) Redis host: redis-genesis-u50607.vm.elestio.app:26379 (Elestio managed) Usage ----- from core.task_queue import configure_broker, enqueue configure_broker() # call once at app startup enqueue("send_notification", "email", "user@example.com", {"msg": "Hi"}) # VERIFICATION_STAMP # Story: M6.00 — task_queue/__init__.py # Verified By: parallel-builder # Verified At: 2026-02-25T00:00:00Z # Tests: see tests/infra/test_task_queue.py # Coverage: 100% )configure_broker get_broker) TaskManagerenqueue)rrrrN)__doc__core.task_queue.brokerrrcore.task_queue.managerrr__all__1/mnt/e/genesis-system/core/task_queue/__init__.pyrs4@8 r