1065
)
1066
task.finish(taskFinishResult{dropReason: dropReasonInvalid})
1068
>
// History will schedule another task once transition ends. Dropping this one.
1069
>
e.logger.Info("dropping activity task during transition",
1070
>
tag.WorkflowTaskQueueName(taskQueueName),
1071
>
tag.WorkflowNamespaceID(task.event.Data.GetNamespaceId()),
1072
>
tag.WorkflowID(task.event.Data.GetWorkflowId()),
1073
>
tag.WorkflowRunID(task.event.Data.GetRunId()),
1074
>
tag.TaskID(task.event.GetTaskId()),
1075
>
tag.WorkflowScheduledEventID(task.event.Data.GetScheduledEventId()),
1076
>
tag.TaskVisibilityTimestamp(timestamp.TimeValue(task.event.Data.GetCreateTime())),
1077
>
tag.VersioningBehavior(task.event.Data.VersionDirective.GetBehavior()),
1078
>
//nolint:staticcheck // SA1019 deprecated WorkerVersionCapabilities will clean up later
1079
>
tag.Deployment(worker_versioning.DeploymentNameFromCapabilities(requestClone.WorkerVersionCapabilities, requestClone.DeploymentOptions)),
1080
>
//nolint:staticcheck // SA1019 deprecated WorkerVersionCapabilities will clean up later
1081
>
tag.BuildId(worker_versioning.BuildIdFromCapabilities(requestClone.WorkerVersionCapabilities, requestClone.DeploymentOptions)),
1082
>
)
1083
>
task.finish(taskFinishResult{dropReason: dropReasonInvalid})
1084
case *serviceerror.ResourceExhausted:
1085
// If history returns one ResourceExhausted, it's likely to return more if we retry