riteshghorse commented on code in PR #21776:
URL: https://github.com/apache/beam/pull/21776#discussion_r894726809
##########
sdks/go/pkg/beam/core/runtime/harness/harness.go:
##########
@@ -140,6 +118,19 @@ func Main(ctx context.Context, loggingEndpoint,
controlEndpoint string, options
state: &StateChannelManager{},
cache: &sideCache,
}
+
+ // if the runner supports worker status api then expose SDK harness
status
+ if statusEndpoint != "" {
+ statusHandler, err := newWorkerStatusHandler(ctx,
statusEndpoint, ctrl.metStore, ctrl.cache)
Review Comment:
I've modified the struct to contain a func implemented by ctrl for getting
active bundle process states. I thought of passing the ctrl itself to the
`newStatusHandler` but that would be an overhead since we just care about 1/2
fields of all the available ones.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
