upgrade SDK to v1.44.0 (#11267)

## What changed?

Upgrade SDK to v1.44.0.

## Why?

Keep up with SDK releases.

## How did you test it?
- [ ] built
- [ ] run locally and tested manually
- [ ] covered by existing tests
- [ ] added new unit test(s)
- [ ] added new functional test(s)

## Potential risks
This commit is contained in:
Tom Dyas
2026-07-24 12:06:35 -07:00
committed by GitHub
parent 46abbc826f
commit e12825e128
3 changed files with 132 additions and 3 deletions

View File

@@ -114,6 +114,20 @@ func (mr *MockClientMockRecorder) CompleteActivityByActivityID(ctx, namespace, a
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CompleteActivityByActivityID", reflect.TypeOf((*MockClient)(nil).CompleteActivityByActivityID), ctx, namespace, activityID, activityRunID, result, err)
}
// CompleteActivityByActivityIDWithOptions mocks base method.
func (m *MockClient) CompleteActivityByActivityIDWithOptions(ctx context.Context, opts client.CompleteActivityByActivityIDOptions) error {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "CompleteActivityByActivityIDWithOptions", ctx, opts)
ret0, _ := ret[0].(error)
return ret0
}
// CompleteActivityByActivityIDWithOptions indicates an expected call of CompleteActivityByActivityIDWithOptions.
func (mr *MockClientMockRecorder) CompleteActivityByActivityIDWithOptions(ctx, opts any) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CompleteActivityByActivityIDWithOptions", reflect.TypeOf((*MockClient)(nil).CompleteActivityByActivityIDWithOptions), ctx, opts)
}
// CompleteActivityByID mocks base method.
func (m *MockClient) CompleteActivityByID(ctx context.Context, namespace, workflowID, runID, activityID string, result any, err error) error {
m.ctrl.T.Helper()
@@ -128,6 +142,34 @@ func (mr *MockClientMockRecorder) CompleteActivityByID(ctx, namespace, workflowI
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CompleteActivityByID", reflect.TypeOf((*MockClient)(nil).CompleteActivityByID), ctx, namespace, workflowID, runID, activityID, result, err)
}
// CompleteActivityByIDWithOptions mocks base method.
func (m *MockClient) CompleteActivityByIDWithOptions(ctx context.Context, opts client.CompleteActivityByIDOptions) error {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "CompleteActivityByIDWithOptions", ctx, opts)
ret0, _ := ret[0].(error)
return ret0
}
// CompleteActivityByIDWithOptions indicates an expected call of CompleteActivityByIDWithOptions.
func (mr *MockClientMockRecorder) CompleteActivityByIDWithOptions(ctx, opts any) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CompleteActivityByIDWithOptions", reflect.TypeOf((*MockClient)(nil).CompleteActivityByIDWithOptions), ctx, opts)
}
// CompleteActivityWithOptions mocks base method.
func (m *MockClient) CompleteActivityWithOptions(ctx context.Context, opts client.CompleteActivityOptions) error {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "CompleteActivityWithOptions", ctx, opts)
ret0, _ := ret[0].(error)
return ret0
}
// CompleteActivityWithOptions indicates an expected call of CompleteActivityWithOptions.
func (mr *MockClientMockRecorder) CompleteActivityWithOptions(ctx, opts any) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CompleteActivityWithOptions", reflect.TypeOf((*MockClient)(nil).CompleteActivityWithOptions), ctx, opts)
}
// CountActivities mocks base method.
func (m *MockClient) CountActivities(ctx context.Context, options client.CountActivitiesOptions) (*client.CountActivitiesResult, error) {
m.ctrl.T.Helper()
@@ -143,6 +185,21 @@ func (mr *MockClientMockRecorder) CountActivities(ctx, options any) *gomock.Call
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CountActivities", reflect.TypeOf((*MockClient)(nil).CountActivities), ctx, options)
}
// CountNexusOperations mocks base method.
func (m *MockClient) CountNexusOperations(ctx context.Context, options client.CountNexusOperationsOptions) (*client.CountNexusOperationsResult, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "CountNexusOperations", ctx, options)
ret0, _ := ret[0].(*client.CountNexusOperationsResult)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// CountNexusOperations indicates an expected call of CountNexusOperations.
func (mr *MockClientMockRecorder) CountNexusOperations(ctx, options any) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CountNexusOperations", reflect.TypeOf((*MockClient)(nil).CountNexusOperations), ctx, options)
}
// CountWorkflow mocks base method.
func (m *MockClient) CountWorkflow(ctx context.Context, request *workflowservice.CountWorkflowExecutionsRequest) (*workflowservice.CountWorkflowExecutionsResponse, error) {
m.ctrl.T.Helper()
@@ -286,6 +343,20 @@ func (mr *MockClientMockRecorder) GetActivityHandle(options any) *gomock.Call {
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetActivityHandle", reflect.TypeOf((*MockClient)(nil).GetActivityHandle), options)
}
// GetNexusOperationHandle mocks base method.
func (m *MockClient) GetNexusOperationHandle(options client.GetNexusOperationHandleOptions) client.NexusOperationHandle {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "GetNexusOperationHandle", options)
ret0, _ := ret[0].(client.NexusOperationHandle)
return ret0
}
// GetNexusOperationHandle indicates an expected call of GetNexusOperationHandle.
func (mr *MockClientMockRecorder) GetNexusOperationHandle(options any) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetNexusOperationHandle", reflect.TypeOf((*MockClient)(nil).GetNexusOperationHandle), options)
}
// GetSearchAttributes mocks base method.
func (m *MockClient) GetSearchAttributes(ctx context.Context) (*workflowservice.GetSearchAttributesResponse, error) {
m.ctrl.T.Helper()
@@ -433,6 +504,21 @@ func (mr *MockClientMockRecorder) ListClosedWorkflow(ctx, request any) *gomock.C
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListClosedWorkflow", reflect.TypeOf((*MockClient)(nil).ListClosedWorkflow), ctx, request)
}
// ListNexusOperations mocks base method.
func (m *MockClient) ListNexusOperations(ctx context.Context, options client.ListNexusOperationsOptions) (client.ListNexusOperationsResult, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "ListNexusOperations", ctx, options)
ret0, _ := ret[0].(client.ListNexusOperationsResult)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// ListNexusOperations indicates an expected call of ListNexusOperations.
func (mr *MockClientMockRecorder) ListNexusOperations(ctx, options any) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListNexusOperations", reflect.TypeOf((*MockClient)(nil).ListNexusOperations), ctx, options)
}
// ListOpenWorkflow mocks base method.
func (m *MockClient) ListOpenWorkflow(ctx context.Context, request *workflowservice.ListOpenWorkflowExecutionsRequest) (*workflowservice.ListOpenWorkflowExecutionsResponse, error) {
m.ctrl.T.Helper()
@@ -463,6 +549,21 @@ func (mr *MockClientMockRecorder) ListWorkflow(ctx, request any) *gomock.Call {
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListWorkflow", reflect.TypeOf((*MockClient)(nil).ListWorkflow), ctx, request)
}
// NewNexusClient mocks base method.
func (m *MockClient) NewNexusClient(options client.NexusClientOptions) (client.NexusClient, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "NewNexusClient", options)
ret0, _ := ret[0].(client.NexusClient)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// NewNexusClient indicates an expected call of NewNexusClient.
func (mr *MockClientMockRecorder) NewNexusClient(options any) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "NewNexusClient", reflect.TypeOf((*MockClient)(nil).NewNexusClient), options)
}
// NewWithStartWorkflowOperation mocks base method.
func (m *MockClient) NewWithStartWorkflowOperation(options client.StartWorkflowOptions, workflow any, args ...any) client.WithStartWorkflowOperation {
m.ctrl.T.Helper()
@@ -569,6 +670,34 @@ func (mr *MockClientMockRecorder) RecordActivityHeartbeatByID(ctx, namespace, wo
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RecordActivityHeartbeatByID", reflect.TypeOf((*MockClient)(nil).RecordActivityHeartbeatByID), varargs...)
}
// RecordActivityHeartbeatByIDWithOptions mocks base method.
func (m *MockClient) RecordActivityHeartbeatByIDWithOptions(ctx context.Context, opts client.RecordActivityHeartbeatByIDOptions) error {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "RecordActivityHeartbeatByIDWithOptions", ctx, opts)
ret0, _ := ret[0].(error)
return ret0
}
// RecordActivityHeartbeatByIDWithOptions indicates an expected call of RecordActivityHeartbeatByIDWithOptions.
func (mr *MockClientMockRecorder) RecordActivityHeartbeatByIDWithOptions(ctx, opts any) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RecordActivityHeartbeatByIDWithOptions", reflect.TypeOf((*MockClient)(nil).RecordActivityHeartbeatByIDWithOptions), ctx, opts)
}
// RecordActivityHeartbeatWithOptions mocks base method.
func (m *MockClient) RecordActivityHeartbeatWithOptions(ctx context.Context, opts client.RecordActivityHeartbeatOptions) error {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "RecordActivityHeartbeatWithOptions", ctx, opts)
ret0, _ := ret[0].(error)
return ret0
}
// RecordActivityHeartbeatWithOptions indicates an expected call of RecordActivityHeartbeatWithOptions.
func (mr *MockClientMockRecorder) RecordActivityHeartbeatWithOptions(ctx, opts any) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RecordActivityHeartbeatWithOptions", reflect.TypeOf((*MockClient)(nil).RecordActivityHeartbeatWithOptions), ctx, opts)
}
// ResetWorkflowExecution mocks base method.
func (m *MockClient) ResetWorkflowExecution(ctx context.Context, request *workflowservice.ResetWorkflowExecutionRequest) (*workflowservice.ResetWorkflowExecutionResponse, error) {
m.ctrl.T.Helper()

2
go.mod
View File

@@ -68,7 +68,7 @@ require (
go.opentelemetry.io/otel/trace v1.44.0
go.temporal.io/api v1.63.4
go.temporal.io/auto-scaled-workers v0.0.0-20260706201056-4320b34799ee
go.temporal.io/sdk v1.41.1
go.temporal.io/sdk v1.44.0
go.uber.org/fx v1.24.0
go.uber.org/goleak v1.3.0
go.uber.org/mock v0.6.0

4
go.sum
View File

@@ -483,8 +483,8 @@ go.temporal.io/api v1.63.4 h1:p4dVIAP3dJop0MfcyH9QSzjU7+V/ttLDhxFhSRUar58=
go.temporal.io/api v1.63.4/go.mod h1:SrlW2JMwVlDP4nRWSNznUFqnSHd+YeMDS1BkYo63HCQ=
go.temporal.io/auto-scaled-workers v0.0.0-20260706201056-4320b34799ee h1:y6A65Iml06cR3CpxW2Zn8FQLjniPDTnN4jtr69UZxXI=
go.temporal.io/auto-scaled-workers v0.0.0-20260706201056-4320b34799ee/go.mod h1:hhHijO9XRPIkAflLJJHix61M9FzbRPqk8fSydkcLkqw=
go.temporal.io/sdk v1.41.1 h1:yOpvsHyDD1lNuwlGBv/SUodCPhjv9nDeC9lLHW/fJUA=
go.temporal.io/sdk v1.41.1/go.mod h1:/InXQT5guZ6AizYzpmzr5avQ/GMgq1ZObcKlKE2AhTc=
go.temporal.io/sdk v1.44.0 h1:suitPDukX74rW3/N1FqvEbZTZVJJsxMKhv0KMa/j7pU=
go.temporal.io/sdk v1.44.0/go.mod h1:vkApR12F9/Y8OR+hkxe7WyXQFuCX6clhzqnAk6rzDAM=
go.uber.org/atomic v1.5.0/go.mod h1:sABNBOSYdrvTF6hTgEIbc7YasKWGhgEQZyfxyTvoXHQ=
go.uber.org/atomic v1.7.0/go.mod h1:fEN4uk6kAWBTFdckzkM89CLk9XfWZrxpCo0nPH17wJc=
go.uber.org/atomic v1.11.0 h1:ZvwS0R+56ePWxUNi+Atn9dWONBPp/AUETXlHW0DxSjE=