107
task.Attempt = executable.Attempt()
108
return respond(e.executeChasmSideEffectTask(ctx, task))
110
>
if executable.Attempt() > workercommands.MaxTaskAttempts {
111
>
e.logger.Info("Worker commands task exceeded max attempts, dropping",
112
>
tag.WorkflowID(task.WorkflowID),
113
>
tag.WorkflowRunID(task.RunID),
114
>
tag.NewStringTag("control_queue", task.Destination),
115
>
tag.Attempt(int32(executable.Attempt())),
116
>
)
117
>
workercommands.RecordCommandMetrics(task.Commands, e.metricsHandler, namespaceTag.Value, "max_attempts_exceeded")
118
>
return respond(nil)
119
>
}
120
return respond(e.workerCommandsDispatcher.Execute(ctx, task, namespaceTag.Value))
121
}