6164
}
6165
6167
return nil, errBatchAPINotAllowed
6168
}
6169
6170
>
maxPageSize := int32(wh.config.VisibilityMaxPageSize(request.GetNamespace()))
workflow_handler.go
6171
>
if request.GetPageSize() <= 0 || request.GetPageSize() > maxPageSize {
6172
>
request.PageSize = maxPageSize
6173
>
}
6174
6175
>
resp, err := wh.ListWorkflowExecutions(ctx, &workflowservice.ListWorkflowExecutionsRequest{
workflow_handler.go
6176
>
Namespace: request.GetNamespace(),
6177
>
PageSize: request.PageSize,
6178
>
NextPageToken: request.GetNextPageToken(),
6179
>
Query: fmt.Sprintf("%s = '%s'",
6180
>
sadefs.TemporalNamespaceDivision,
6181
>
batcher.NamespaceDivision,
6182
>
),
6183
>
})
6184
>
if err != nil {
6185
return nil, err
6186
}
6187
6189
>
for _, execution := range resp.GetExecutions() {
6190
>
// Batch operations started before the operation type was recorded in the
6191
>
// memo do not have this field, so they default to the zero value
6192
>
// BATCH_OPERATION_TYPE_UNSPECIFIED.
6193
>
var operationType enumspb.BatchOperationType
6194
>
if typePayload, ok := execution.GetMemo().GetFields()[batcher.BatchOperationTypeMemo]; ok {
6195
>
var operationTypeString string
6196
>
if err := payload.Decode(typePayload, &operationTypeString); err != nil {
6197
return nil, err
6198
}
6200
}
6202
>
JobId: execution.GetExecution().GetWorkflowId(),
6203
>
State: getBatchOperationState(execution.GetStatus()),
6204
>
StartTime: execution.GetStartTime(),
6205
>
CloseTime: execution.GetCloseTime(),
6206
>
OperationType: operationType,
6207
>
})
6208
}
6210
>
OperationInfo: operations,
6211
>
NextPageToken: resp.NextPageToken,
6212
>
}, nil
6213
}
6214