214
return nil, fmt.Errorf("%w: %w", errOpProcessorFailed, err)
215
}
216
>
resp, err := i.historyClient.StartNexusOperation(ctx, &historyservice.StartNexusOperationRequest{
invocation.go
217
>
NamespaceId: i.ns.ID().String(),
218
>
ShardId: res.RoutingKey.ShardID(i.config.NumHistoryShards),
219
>
Request: &nexuspb.StartOperationRequest{
220
>
Service: args.service,
221
>
Operation: args.operation,
222
>
Payload: res.ReserializedInputPayload,
223
>
RequestId: args.requestID,
224
>
Callback: options.CallbackURL,
225
>
CallbackHeader: options.CallbackHeader,
226
>
Links: protoLinks,
227
>
},
228
>
})
229
>
if err != nil {
230
return nil, err
231
}