95
}
96
97
>
func (a *LocalActivities) GetNextPageTokenActivity(ctx context.Context, params GetNextPageTokenParams) ([]byte, error) {
activities.go
98
>
ctx = headers.SetCallerName(ctx, params.Namespace.String())
99
>
100
>
req := &manager.ListWorkflowExecutionsRequestV2{
101
>
NamespaceID: params.NamespaceID,
102
>
Namespace: params.Namespace,
103
>
PageSize: params.PageSize,
104
>
NextPageToken: params.NextPageToken,
105
>
Query: sadefs.QueryWithAnyNamespaceDivision(""),
106
>
}
107
>
108
>
resp, err := a.visibilityManager.ListWorkflowExecutions(ctx, req)
109
>
if err != nil {
110
a.logger.Error("Unable to list all workflows to get next page token.", tag.WorkflowNamespace(params.Namespace.String()), tag.WorkflowNamespaceID(params.NamespaceID.String()), tag.Error(err))
111
return nil, err
112
}
113
115
}
116
117
>
func (a *Activities) DeleteExecutionsActivity(ctx context.Context, params DeleteExecutionsActivityParams) (DeleteExecutionsActivityResult, error) {
activities.go
118
>
ctx = headers.SetCallerName(ctx, params.Namespace.String())
119
>
logger := log.With(a.logger,
120
>
tag.WorkflowNamespace(params.Namespace.String()),
121
>
tag.WorkflowNamespaceID(params.NamespaceID.String()))
122
>
123
>
progressCh := make(chan DeleteExecutionsActivityResult, 1)
124
>
defer func() { close(progressCh) }()
125
127
>
if activity.HasHeartbeatDetails(ctx) {
128
var previousAttemptResult DeleteExecutionsActivityResult
129
if err := activity.GetHeartbeatDetails(ctx, &previousAttemptResult); err != nil {