fix(eda): worker subscribed to a dead topic — async extractions never processed

CHANGELOG.md

@@ -6,6 +6,23 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.1.0/),
 and this project uses **CalVer `YY.M.PP`** (PEP 440 may normalise patch numbers
 for the Python wheel — e.g. `26.06.00` → `26.6.0`).
 
+## [26.6.4] - 2026-06-12
+
+### Fixed
+
+- **Async worker consumed no jobs (wrong EDA topic).** `pyfly.eda.destinations`
+  defaulted to `flydocs.jobs`, but the submit handler publishes
+  `extraction.submitted` to `jobs_topic` = `flydocs.extractions`. The `worker`
+  container therefore subscribed to a topic nothing publishes to, so every
+  queued async extraction sat unprocessed (only the reaper eventually revived
+  it). Aligned the `destinations` default to `flydocs.extractions` — still
+  env-overridable via `FLYDOCS_EDA_DESTINATIONS`, and `bbox-worker` keeps its
+  own `flydocs.extractions.post_processing` override.
+
+### Changed
+
+- Bumped the locked `pyfly` framework dependency to `26.6.99`.
+
 ## [26.6.3] - 2026-06-12
 
 ### Added

pyfly.yaml

@@ -68,9 +68,11 @@ pyfly:
     enabled: true
     provider: ${FLYDOCS_EDA_ADAPTER:postgres}
     # Both knobs are env-overridable so the ``bbox-worker`` container can
-    # subscribe to ``flydocs.bbox.refine`` under its own consumer
-    # group while the main ``worker`` keeps consuming ``flydocs.jobs``.
-    destinations: ${FLYDOCS_EDA_DESTINATIONS:flydocs.jobs}
+    # subscribe to ``flydocs.extractions.post_processing`` under its own
+    # consumer group while the main ``worker`` consumes ``flydocs.extractions``
+    # (matching ``IDPSettings.jobs_topic`` -- the topic the submit handler
+    # publishes ``extraction.submitted`` to).
+    destinations: ${FLYDOCS_EDA_DESTINATIONS:flydocs.extractions}
     group: ${FLYDOCS_EDA_GROUP:flydocs-workers}
     postgres:
       dsn: ${FLYDOCS_DATABASE_URL:postgresql+asyncpg://idp:idp@localhost:5432/flydocs}

pyproject.toml

@@ -2,7 +2,7 @@
 name = "flydocs"
 # CalVer YY.MM.PP -- bumped per release. Note that PEP 440 normalises
 # ``26.05.01`` -> ``26.5.1`` in the built wheel filename.
-version = "26.6.3"
+version = "26.6.4"
 description = "Pure-multimodal Intelligent Document Processing service: structured fields + bounding boxes, validation, authenticity checks, LLM judge, and a business-rule engine. Sync + queue-backed async APIs over fireflyframework-pyfly and -agentic. Part of Firefly OperationOS, platform-agnostic by design."
 readme = "README.md"
 requires-python = ">=3.13"