Repository navigation
worker_telemetry repeats the decode that _decode_text provides #81
Description
Activity
- changed the title
[-]worker_telemetry hand-rolls the decode _decode_text provides[/-][+]worker_telemetry repeats the decode that _decode_text provides[/+]on Oct 5, 2026 The
_decode_texthelper is gone, so there is no helper left to reuse. The module decodes each reply at its read site.worker_telemetrydecodes its pubsub data inline.
Found while reviewing PR #69 with the SuperJoe crew. Filed as out-of-scope there.
RedisTaskBackend.worker_telemetry()decodes each pub/sub message withdata.decode() if isinstance(data, bytes) else data._decode_text()now applies the same bytes-or-str rule in this module. The helper also covers the missing reply. AREDIS_URLwithdecode_responses=Truereaches both paths. The helper keeps the reply-shape rule in one place. That is why it exists.Reference:
threadmill/backends/redis.py,worker_telemetry.