552
}
553
554
>
func (h *Handler) RespondNexusTaskCompleted(ctx context.Context, request *matchingservice.RespondNexusTaskCompletedRequest) (_ *matchingservice.RespondNexusTaskCompletedResponse, retError error) {
handler.go
555
>
defer log.CapturePanic(h.logger, &retError)
556
>
opMetrics := h.opMetricsHandler(
557
>
request.GetNamespaceId(),
558
>
request.GetTaskQueue(),
559
>
enumspb.TASK_QUEUE_TYPE_NEXUS,
560
>
metrics.MatchingRespondNexusTaskCompletedScope,
561
>
)
562
>
h.recordNexusTaskRequest(ctx, request.GetNamespaceId(), request.GetTaskQueue().GetKind(), "RespondNexusTaskCompleted")
563
>
564
>
return h.engine.RespondNexusTaskCompleted(ctx, request, opMetrics)
565
>
}
566
567
func (h *Handler) RespondNexusTaskFailed(ctx context.Context, request *matchingservice.RespondNexusTaskFailedRequest) (_ *matchingservice.RespondNexusTaskFailedResponse, retError error) {