nx_queue_drain.nx

nx_queue_drain.nx -- THE ANTI-PUBLISHER-DEATH SPINE: decide + disposition every queued gap so the queue DRAINS, never "clogs and dies." Operator 2026-07-04: "we need THEM to DECIDE and get these things FIXED till they are trusted like you are -- i can't have the nishi publisher situation where the queue clogs and dies." GROUNDED (researcher): dead-letter queue (a failed item gets a FAILED disposition, is NEVER silently dropped/ stuck -- drain_deadletter.raw) + Little's law (if arrival-rate > service-rate, depth -> infinity = the death; so we MEASURE fill-vs-drain and ALARM -- drain_littleslaw.raw). COMPOSES the proven anti-clog primitives: nx_eval_queue (the work items + the new _key/_status/_close enumeration) + the hostop_watchdog pattern (heartbeat so a hung drainer is RESTARTED, not silently dead). THE GUARANTEE (why it can't clog + die): (1) EVERY OPEN item gets a DISPOSITION each pass -- routed to its owner (a council proposal for high-blast; auto-close for done-evidence) or DEAD-LETTERED with a reason if it cannot be processed. Nothing stays silently OPEN forever. (2) The drainer HEARTBEATS -> a watchdog relaunches it if it hangs. (3) A HEALTH census reports remaining/dead-lettered + ALARMS if remaining only grows (fill > drain) -- the publisher-death DETECTOR that was missing. HONEST: it DECIDES + ROUTES + tracks every item; it does not claim to auto-FIX arbitrary gaps (targeted synthesis is the team's open arc) -- unfixable-here items are dead-lettered + ESCALATED (visible), the trust-building transparency. license_tier: ORIGINAL genealogy_id: international-research-sources/{dead_letter_queue,littles_law} + operator-2026-07-04-queue-death lineage_id: nishi_queue_drain_v1 expect_exit: 0