search

peter-wangxu / persist-queue

A thread-safe disk based persistent queue in Python
BSD 3-Clause "New" or "Revised" License
335 stars 50 forks source link

qsize not changing #171

Closed KillahB33 closed 3 years ago

KillahB33 commented 3 years ago

I looked through the issues but the only "fix" I found was deleting the queue which doesn't make sense to me. Basically I have some code that puts records into my file type queue, then later get() them and if the task they are used for is successful I do a task_done on the appropriate queue, but qsize is still reporting as 2 even though I have done a get() on both those records.

KillahB33 commented 3 years ago

Apologies, this was me making a mistake elsewhere in the code so my count wasn't being updated.