diff --git a/go.mod b/go.mod index 5942a842c1..3a0f8a2c15 100644 --- a/go.mod +++ b/go.mod @@ -58,7 +58,7 @@ require ( go.opentelemetry.io/otel/sdk v1.34.0 go.opentelemetry.io/otel/sdk/metric v1.34.0 go.opentelemetry.io/otel/trace v1.34.0 - go.temporal.io/api v1.59.1-0.20251203230651-7773526824c5 + go.temporal.io/api v1.59.1-0.20251205215512-1b49af22324a go.temporal.io/sdk v1.35.0 go.uber.org/fx v1.24.0 go.uber.org/mock v0.6.0 diff --git a/go.sum b/go.sum index 09f081782e..4d74230c5a 100644 --- a/go.sum +++ b/go.sum @@ -390,8 +390,8 @@ go.opentelemetry.io/otel/trace v1.34.0 h1:+ouXS2V8Rd4hp4580a8q23bg0azF2nI8cqLYnC go.opentelemetry.io/otel/trace v1.34.0/go.mod h1:Svm7lSjQD7kG7KJ/MUHPVXSDGz2OX4h0M2jHBhmSfRE= go.opentelemetry.io/proto/otlp v1.5.0 h1:xJvq7gMzB31/d406fB8U5CBdyQGw4P399D1aQWU/3i4= go.opentelemetry.io/proto/otlp v1.5.0/go.mod h1:keN8WnHxOy8PG0rQZjJJ5A2ebUoafqWp0eVQ4yIXvJ4= -go.temporal.io/api v1.59.1-0.20251203230651-7773526824c5 h1:7lFIrLVM+NPVcqFMrEwv5d8D9meA7n/Xl9GtCl8Gyhc= -go.temporal.io/api v1.59.1-0.20251203230651-7773526824c5/go.mod h1:iaxoP/9OXMJcQkETTECfwYq4cw/bj4nwov8b3ZLVnXM= +go.temporal.io/api v1.59.1-0.20251205215512-1b49af22324a h1:eGsL32R3c2rlc6v56XI+vNtUViPONS5kyXW2OPh3d0U= +go.temporal.io/api v1.59.1-0.20251205215512-1b49af22324a/go.mod h1:iaxoP/9OXMJcQkETTECfwYq4cw/bj4nwov8b3ZLVnXM= go.temporal.io/sdk v1.35.0 h1:lRNAQ5As9rLgYa7HBvnmKyzxLcdElTuoFJ0FXM/AsLQ= go.temporal.io/sdk v1.35.0/go.mod h1:1q5MuLc2MEJ4lneZTHJzpVebW2oZnyxoIOWX3oFVebw= go.uber.org/atomic v1.5.0/go.mod h1:sABNBOSYdrvTF6hTgEIbc7YasKWGhgEQZyfxyTvoXHQ= diff --git a/service/frontend/namespace_handler.go b/service/frontend/namespace_handler.go index 0b1c46fe24..bd06f743db 100644 --- a/service/frontend/namespace_handler.go +++ b/service/frontend/namespace_handler.go @@ -862,6 +862,7 @@ func (d *namespaceHandler) createResponse( AsyncUpdate: d.config.EnableUpdateWorkflowExecutionAsyncAccepted(info.Name), ReportedProblemsSearchAttribute: numConsecutiveWorkflowTaskProblemsToTriggerSearchAttribute > 0, WorkerHeartbeats: d.config.WorkerHeartbeatsEnabled(info.Name), + WorkflowPause: d.config.WorkflowPauseEnabled(info.Name), }, Limits: &namespacepb.NamespaceInfo_Limits{ BlobSizeLimitError: int64(d.config.BlobSizeLimitError(info.Name)), diff --git a/service/frontend/namespace_handler_test.go b/service/frontend/namespace_handler_test.go index 0eb3e34401..83a4c45321 100644 --- a/service/frontend/namespace_handler_test.go +++ b/service/frontend/namespace_handler_test.go @@ -384,6 +384,7 @@ func (s *namespaceHandlerCommonSuite) TestCapabilitiesAndLimits() { s.True(resp.NamespaceInfo.Capabilities.AsyncUpdate) s.True(resp.NamespaceInfo.Capabilities.ReportedProblemsSearchAttribute) s.True(resp.NamespaceInfo.Capabilities.WorkerHeartbeats) + s.False(resp.NamespaceInfo.Capabilities.WorkflowPause) s.Equal(int64(2*1024*1024), resp.NamespaceInfo.Limits.BlobSizeLimitError) s.Equal(int64(2*1024*1024), resp.NamespaceInfo.Limits.MemoSizeLimitError) @@ -393,6 +394,7 @@ func (s *namespaceHandlerCommonSuite) TestCapabilitiesAndLimits() { s.config.EnableUpdateWorkflowExecutionAsyncAccepted = dc.GetBoolPropertyFnFilteredByNamespace(false) s.config.NumConsecutiveWorkflowTaskProblemsToTriggerSearchAttribute = dc.GetIntPropertyFnFilteredByNamespace(5) s.config.WorkerHeartbeatsEnabled = dc.GetBoolPropertyFnFilteredByNamespace(false) + s.config.WorkflowPauseEnabled = dc.GetBoolPropertyFnFilteredByNamespace(true) s.config.BlobSizeLimitError = dc.GetIntPropertyFnFilteredByNamespace(1024) s.config.MemoSizeLimitError = dc.GetIntPropertyFnFilteredByNamespace(512) @@ -405,6 +407,7 @@ func (s *namespaceHandlerCommonSuite) TestCapabilitiesAndLimits() { s.False(resp.NamespaceInfo.Capabilities.AsyncUpdate) s.True(resp.NamespaceInfo.Capabilities.ReportedProblemsSearchAttribute) s.False(resp.NamespaceInfo.Capabilities.WorkerHeartbeats) + s.True(resp.NamespaceInfo.Capabilities.WorkflowPause) s.Equal(int64(1024), resp.NamespaceInfo.Limits.BlobSizeLimitError) s.Equal(int64(512), resp.NamespaceInfo.Limits.MemoSizeLimitError) }