5763
}
5764
5766
>
5767
>
namespaceID, err := wh.namespaceRegistry.GetNamespaceID(namespace.Name(request.GetNamespace()))
5768
>
if err != nil {
5769
return nil, err
5770
}
5771
5773
>
Request: request,
5774
>
NamespaceId: namespaceID.String(),
5775
>
}
5776
>
5777
>
var identity string
5778
>
//nolint:staticcheck // SA1019: persist legacy values so a batch can resume on a pre-upgrade worker
5779
>
switch op := request.Operation.(type) {
5780
case *workflowservice.StartBatchOperationRequest_TerminateActivitiesOperation:
5781
input.BatchType = enumspb.BATCH_OPERATION_TYPE_TERMINATE_ACTIVITY