109
matchingClient matchingservice.MatchingServiceClient,
110
routingInfoCache worker_versioning.RoutingInfoCache,
112
>
namespaceEntry, err := api.GetActiveNamespace(shardContext, namespace.ID(request.GetNamespaceId()), request.WorkflowExecution.WorkflowId)
113
>
if err != nil {
114
return nil, rejectCodeUndefined, err
115
}
117
>
118
>
scheduledEventID := request.GetScheduledEventId()
119
>
requestID := request.GetRequestId()
120
>
ai, isRunning := mutableState.GetActivityInfo(scheduledEventID)
121
>
122
>
taggedMetrics := shardContext.GetMetricsHandler().WithTags(metrics.OperationTag(metrics.HistoryRecordActivityTaskStartedScope))
123
>
124
>
// First check to see if cache needs to be refreshed as we could potentially have stale workflow execution in
125
>
// some extreme cassandra failure cases.
126
>
if !isRunning && scheduledEventID >= mutableState.GetNextEventID() {
127
metrics.StaleMutableStateCounter.With(taggedMetrics).Record(1)
128
return nil, rejectCodeUndefined, consts.ErrStaleState