75
// will not be persisted.
76
if writeErr == nil || !persistence.OperationPossiblySucceeded(writeErr) {
77
>
// we can only remove the task from the pending task list if we are sure it was inserted
task_request_tracker.go
78
>
// or the insertion is guaranteed to have failed
79
>
for category, minKey := range minKeyByCategory {
80
delete(t.pendingTaskKeys[category], minKey)
81
}