HF RL Explorer

Race condition in stream package causes panic when fetching from a closed streamer

Race condition in stream package causes panic when fetching from a closed streamer: a task in LegoFlow-SWE (Harbor dataset). The root cause is that the backoff calculation ( streamerFetchIntervalDurationMs (1 << retries) ) yields streamerFetchIntervalDurationMs 1 when retries is 0 . Combined with…

The task

The root cause is that the backoff calculation (`streamerFetchIntervalDurationMs * (1 << retries)`) yields `streamerFetchIntervalDurationMs * 1` when `retries` is `0`. Combined with jitter, this can produce a `fetchDelay` extremely close to zero. Since `retries` is reset to `0` on the final fetch (when the…

Part of Lego-X/LegoFlow-SWE.