121
common.IsContextDeadlineExceededErr(err) ||
122
common.IsContextCanceledErr(err)) {
123
>
// TODO(pri): if this was a start error (not a forwarding error): consider adding a
pri_task_reader.go
124
>
// per-task backoff here, in case the error was workflow busy, we don't want to end up
125
>
// trying the same task immediately. maybe also: after a few attempts on the same task,
126
>
// let it get cycled to the end of the queue, in case there's some task/wf-specific
127
>
// thing.
128
>
tr.addTaskToMatcher(task)
129
>
return
130
>
}
131
132
// On other errors: ask backlog manager to re-spool to persistence