Loss of progress events

- my queue has 3 workers
- each worker processes a task that can last few minutes (e.g. 1-3 minutes)
- each worker, while processing a task, sends a progress

- about every 2/3 seconds
- the payload of each progress event is few MB (~1.5MB)

The client that receives the progress does not receive all the events.

Somewhere the progress events are lost.

Any recommendation to better investigate?

No files, tests, or entry points are named. Reproduce the setup with three workers, multi-minute tasks, progress events every 2–3 seconds, and payloads of about 1.5 MB, then trace delivery from worker emission to the receiving client. Done means identifying where events are lost and documenting or fixing the behavior with a regression test.

Written by the indexing model from the issue text.