LegacyHUB/app/integrations/dispatch_inbox_consumer.py at main

Vadim_Malanov/LegacyHUB

Fork 0

Files

Vadim Malanov 272cbf6d92

CI / Backend (lint + tests + compose) (push) Has been cancelled

Details

CI / Frontend (lint + type-check + build) (push) Has been cancelled

Details

feat(dispatch): consume QMS asset events from the service inbox (C2)

LegacyHUB is subscribed to AssetRegistered/AssetApproved from QMS but
never polled its service inbox. New consumer maps the §7 payload to an
AssetManifestEnvelope and runs the local knowledge-ingest, then confirms
the delivery. Outcome policy avoids head-of-line blocking: Registered →
ingest (accepted/duplicate/rejected all confirm), Approved/unknown →
confirm without work, malformed → confirm as poison; only transient
infrastructure failures (object_read_failed) leave the message pending
and stop the run for the next scheduled retry. Thin CLI wrapper
scripts/consume_dispatch_inbox.py (scripts/ ships in the image).

Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>

2026-07-12 12:39:44 +03:00

7.5 KiB

Raw Permalink Blame History

View Raw

7.5 KiB Raw Permalink Blame History

7.5 KiB

Raw Permalink Blame History