The idea here is that if the pipeline is not running then we simply publish the state in L220 and if it is running then we would have published the state in L215 and we will not republish till the state changes to something other than running.
[ Full content available at: https://github.com/apache/beam/pull/6301 ] This message was relayed via gitbox.apache.org for [email protected]
