from persistqueue import SQLiteQueue
q = SQLiteQueue(path="/tmp/queue", auto_commit=True)
q.put(item={ "pqid": 100, "name": "william" })
x = q.get(id={ "pqid": 100, "name": "william" })
pprint(x)
After playing around more with this I noticed that even though pqid was set in the put method. it returns the latest sequence number of the sql table i.e 1 instead of 100
I tried setting timeout=0 but it raises Empty error.
After playing around more with this I noticed that even though pqid was set in the put method. it returns the latest sequence number of the sql table i.e
1instead of100I tried setting
timeout=0but it raises Empty error.