1131
return nil, fmt.Errorf("%w: %w", errOpProcessorFailed, err)
1132
}
1133
>
resp, err := e.HistoryClient.StartNexusOperation(ctx, &historyservice.StartNexusOperationRequest{
executors.go
1134
>
NamespaceId: ns.ID().String(),
1135
>
ShardId: res.RoutingKey.ShardID(e.Config.NumHistoryShards),
1136
>
// NOTE: Header is not allowed for system operations.
1137
>
Request: &nexuspb.StartOperationRequest{
1138
>
Service: args.service,
1139
>
Operation: args.operation,
1140
>
Payload: res.ReserializedInputPayload,
1141
>
RequestId: args.requestID,
1142
>
Callback: options.CallbackURL,
1143
>
CallbackHeader: options.CallbackHeader,
1144
>
Links: protoLinks,
1145
>
},
1146
>
})
1147
>
if err != nil {
1148
return nil, err
1149
}