mongoqueue
mongoqueue copied to clipboard
Attempts counter resets everytime on queue.next()
-
Defined queue = MongoQueue( ... Connection(TEST_DB).doctest_queue, ... consumer_id="consumer-1", ... timeout=300, ... max_attempts=3)
-
Then got job by ----- job = queue.next()
-
Job has error ---- job.error("Error") ------- here attempts counter incremented to 2
-
Then again got the same job by ----- job = queue.next() ------ but attempts counter got reset to 1
Question : how will the job be marked failed is attempts counter gets reset?