Determine if limit streams impact metrics propagation #187
Description
Right now, a task will send metrics from the flight endpoint to the client when the last partition's stream has completed.
Does the stream necessarily complete?
Is it possible that the stream completes but the client has moved on from consuming it?
Metrics propagation relies on the stream completing and the client waiting for the last message which contains metrics.
We should look into if adding a limit on the client side causes issues with this scheme.