Good day, Everyone, We are implementing a Cancel and Drain feature for the Prism runner. Please see https://github.com/apache/beam/issues/29669 that contains everything that goes into a design document. For more information about Prism, please see https://github.com/apache/beam/tree/master/sdks/go/pkg/beam/runners/prism
Best, Damon