[FlowControl]fix fresh start flow control

ray-project / mobius

Mobius is an AI infrastructure platform for distributed online learning, including online sample processing, training and serving.

https://ray-project.github.io/mobius/

Apache License 2.0

85 stars 13 forks source link

[FlowControl]fix fresh start flow control #58

Closed ashione closed 1 year ago

ashione commented 1 year ago

Upstream fails to push a new bundle message to downstream since downstream crash and refresh starting with invalid bundle id. This PR detect an invalid notification message and reset new value.