926
}
927
928
>
func (e *matchingEngineImpl) nonRetryableErrorsDropTask(task *internalTask, taskQueueName string, err error) {
matching_engine.go
929
>
e.logger.Error("dropping task due to non-nonretryable errors",
930
>
tag.WorkflowNamespace(task.namespace.String()),
931
>
tag.WorkflowNamespaceID(task.event.Data.GetNamespaceId()),
932
>
tag.WorkflowID(task.event.Data.GetWorkflowId()),
933
>
tag.WorkflowRunID(task.event.Data.GetRunId()),
934
>
tag.WorkflowTaskQueueName(taskQueueName),
935
>
tag.TaskID(task.event.GetTaskId()),
936
>
tag.WorkflowScheduledEventID(task.event.Data.GetScheduledEventId()),
937
>
tag.Error(err),
938
>
tag.ErrorType(err),
939
>
)
940
>
941
>
metrics.NonRetryableTasks.With(e.metricsHandler).Record(1, metrics.ServiceErrorTypeTag(err))
942
>
}
943
944
// PollActivityTaskQueue takes one task from the task manager, update workflow execution history, mark task as