[Prism][Task]: A State Publisher notifies listeners of changes to PipelineResult.State. #32032
Description
What needs to happen?
The Prism runner needs to respond to when a PipelineResult.State::isTerminal before gracefully shutting down various resources. The output of this task is a State Publisher that notifies registered listeners of a change to PipelineResult.State. To achieve this, it relies on the rpc GetStateStream (GetJobStateRequest) returns (stream JobStateEvent); of job_management/v1/beam_job_api.proto.
Issue Priority
Priority: 2 (default / most normal work should be filed as P2)