Open
Description
getting this error thrown... except I only have a maximum of 3 waiters
This is how I dequeue - is there a problem with timing out and rechecking? Does that leak something?
ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
defer cancel()
queuedElement, err := scoutQueue.DequeueOrWaitForNextElementContext(ctx)
if err != nil {
if err != context.DeadlineExceeded {
log.Infof("SCOUT: Unexpected queue error: %s", err)
}
return nil
}Metadata
Metadata
Assignees
Labels
No labels