946
}
947
948
>
func createNexusOperationFailure(operation Operation, scheduledEventID int64, cause *failurepb.Failure) *failurepb.Failure {
executors.go
949
>
return &failurepb.Failure{
950
>
Message: "nexus operation completed unsuccessfully",
951
>
FailureInfo: &failurepb.Failure_NexusOperationExecutionFailureInfo{
952
>
NexusOperationExecutionFailureInfo: &failurepb.NexusOperationFailureInfo{
953
>
Endpoint: operation.Endpoint,
954
>
Service: operation.Service,
955
>
Operation: operation.Operation,
956
>
OperationToken: operation.OperationToken,
957
>
// TODO(bergundy): This field is deprecated, remove it after the 1.27 release.
958
>
OperationId: operation.OperationToken,
959
>
ScheduledEventId: scheduledEventID,
960
>
},
961
>
},
962
>
Cause: cause,
963
>
}
964
>
}
965
966
func startCallOutcomeTag(callCtx context.Context, result *nexusrpc.ClientStartOperationResponse[*commonpb.Payload], callErr error) string {