64
metricsHandler metrics.Handler,
65
logger log.Logger,
67
>
logger = tasks.InitializeLogger(transferTask, logger)
68
>
mutableState, err := loadMutableStateForTask(
69
>
ctx,
70
>
shardContext,
71
>
wfContext,
72
>
transferTask,
73
>
tasks.GetTransferTaskEventID,
74
>
transferTaskMutableStateStaleChecker,
75
>
metricsHandler.WithTags(metrics.OperationTag(metrics.OperationTransferQueueProcessorScope)),
76
>
queues.GetActiveTransferTaskTypeTagValue(transferTask, shardContext.ChasmRegistry()),
77
>
logger,
78
>
)
79
>
if err != nil {
80
// When standby task executor executes task in active cluster (and vice versa),
81
// mutable state might be already deleted by active task executor and NotFound is a valid case which shouldn't be logged.