1019
// drop the task as otherwise task would be stuck in a retry-loop
1020
task.finish(taskFinishResult{dropReason: dropReasonDataLoss})
1021
>
case *serviceerror.NotFound: // mutable state not found, workflow not running or activity info not found
matching_engine.go
1022
>
e.logger.Info("Activity task not found",
1023
>
tag.WorkflowNamespaceID(task.event.Data.GetNamespaceId()),
1024
>
tag.WorkflowID(task.event.Data.GetWorkflowId()),
1025
>
tag.WorkflowRunID(task.event.Data.GetRunId()),
1026
>
tag.WorkflowTaskQueueName(taskQueueName),
1027
>
tag.TaskID(task.event.GetTaskId()),
1028
>
tag.TaskVisibilityTimestamp(timestamp.TimeValue(task.event.Data.GetCreateTime())),
1029
>
tag.WorkflowEventID(task.event.Data.GetScheduledEventId()),
1030
>
tag.Error(err),
1031
>
)
1032
>
task.finish(taskFinishResult{dropReason: dropReasonNotFound})
1033
case *serviceerrors.TaskAlreadyStarted:
1034
e.logger.Debug("Duplicated activity task", tag.WorkflowTaskQueueName(taskQueueName), tag.TaskID(task.event.GetTaskId()))