792
// drop the task as otherwise task would be stuck in a retry-loop
793
task.finish(taskFinishResult{dropReason: dropReasonDataLoss})
794
>
case *serviceerror.NotFound: // mutable state not found, workflow not running or workflow task not found
matching_engine.go
795
>
e.logger.Info("Workflow task not found",
796
>
tag.WorkflowTaskQueueName(taskQueueName),
797
>
tag.WorkflowNamespaceID(task.event.Data.GetNamespaceId()),
798
>
tag.WorkflowID(task.event.Data.GetWorkflowId()),
799
>
tag.WorkflowRunID(task.event.Data.GetRunId()),
800
>
tag.TaskID(task.event.GetTaskId()),
801
>
tag.TaskVisibilityTimestamp(timestamp.TimeValue(task.event.Data.GetCreateTime())),
802
>
tag.WorkflowEventID(task.event.Data.GetScheduledEventId()),
803
>
tag.Error(err),
804
>
)
805
>
task.finish(taskFinishResult{dropReason: dropReasonNotFound})
806
case *serviceerrors.TaskAlreadyStarted:
807
e.logger.Debug("Duplicated workflow task", tag.WorkflowTaskQueueName(taskQueueName), tag.TaskID(task.event.GetTaskId()))