190
// requires success for all defined commands, so this indicates a bug or version
191
// incompatibility. Retrying won't help.
192
>
d.logger.Error("Worker returned failure for worker commands",
dispatcher.go
193
>
tag.WorkflowID(task.WorkflowID),
194
>
tag.WorkflowRunID(task.RunID),
195
>
tag.NewStringTag("control_queue", task.Destination),
196
>
tag.NewInt("command_count", len(task.Commands)),
197
>
tag.Error(nexusErr))
198
>
d.recordCommandMetrics(task.Commands, namespaceName, "worker_error")
199
>
return nil
200
}
201