#794 JumperClient singleton ignores queue_name parameter causing queue contamination

closed critical Created 2026-01-02 19:11 · Updated 2026-01-02 19:14

Description

Edit
Root Cause: get_jumper_client() singleton caches queue_name from first call, ignores subsequent. When /retry endpoint called for workflow on highway_internal queue, singleton initialized with that queue. All subsequent submissions used contaminated singleton routing to highway_internal. Impact: Production workflows after 18:14 on 2025-01-02 went to highway_internal instead of highway_default. Fix: Per-queue singletons using dict[queue_name, JumperClient].

Comments

Loading comments...

Context

Loading context...

Audit History

View All
Loading audit history...