From 282e74ac76b6ae02c2fc98a17ac54ce065b208cb Mon Sep 17 00:00:00 2001 From: riteshghorse Date: Thu, 26 May 2022 13:18:13 -0400 Subject: [PATCH] enable worker status in Go --- sdks/go/pkg/beam/core/runtime/graphx/translate.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/sdks/go/pkg/beam/core/runtime/graphx/translate.go b/sdks/go/pkg/beam/core/runtime/graphx/translate.go index c1416dfba5f2a..6d3b48733e2af 100644 --- a/sdks/go/pkg/beam/core/runtime/graphx/translate.go +++ b/sdks/go/pkg/beam/core/runtime/graphx/translate.go @@ -65,6 +65,7 @@ const ( URNLegacyProgressReporting = "beam:protocol:progress_reporting:v0" URNMultiCore = "beam:protocol:multi_core_bundle_processing:v1" + URNWorkerStatus = "beam:protocol:worker_status:v1" URNRequiresSplittableDoFn = "beam:requirement:pardo:splittable_dofn:v1" URNRequiresBundleFinalization = "beam:requirement:pardo:finalization:v1" @@ -88,6 +89,7 @@ func goCapabilities() []string { URNLegacyProgressReporting, URNMultiCore, URNTruncate, + URNWorkerStatus, // TOOD(BEAM-9614): Make this versioned. "beam:version:sdk_base:go", }