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", }