persist-queue

persist-queue copied to clipboard

Priority queue

4

I haven't found any other active Python projects for managing persistent queues (only little-functional or nearly archived ones). But this has a disadvantage (important for me) - it does not...

ancieg

sqlite vacuum not working

5

I use SQLiteAckQueue with multithreading I periodically run `queue.clear_acked_data()` and `queue.shrink_disk_usage()`. It does not change the queue db file size. When I run VACUUM with sqlite3 manually, the file size...

mo-pyy

Queue gets corrupted after power cut

5

I am using `persistqueue.Queue` to keep track of a list of pending ftp transfers. After an sudden power down of the system the queue can not be loaded. ```python3 from...

jensanjo

Can't dequeue corrupted pickle item

3

Persist-Queue 0.5.0 I don't know how I got into this state, but I have a corrupted queue that I cannot remove items from. ``` >>> import persistqueue >>> q =...

PhracturedBlue

Connection not die after kill signal.

1

I used to have the following code: run.py ```` from tendo import singleton me = singleton.SingleInstance(lockfile='running.lock') # will sys.exit(-1) if other instance is running validated_profiles_queue = persistqueue.SQLiteQueue( os.path.join(Settings.database_location_path, 'valid_users_q'), auto_commit=True)...

instasck

[Regression] Can no longer retrieve None without raw=True

1

It used to work with a previous version, but doesn't work anymore. `None` can still be put inside, but getting it out (without raw) will get stuck ie [here](https://github.com/peter-wangxu/persist-queue/blob/master/persistqueue/sqlqueue.py#L135). Not...

NovaNekmit

- I changed my data ID, and finally I couldn't ack it ```python def _find_item_id(self, item, search=True): if item is None: return None elif isinstance(item, dict) and "pqid" in item:...

cn-kali-team

queue length for SQLiteQueue is incorrect when running in multiple processes

6

Possibly expected behavior, but I think it's worth reporting, because the queue looks usable otherwise. The queue size is set only once on queue creation. ```self.total = self._count()```, so if...

melbaa

Unique value or methods to check if item already exists

2

Hi, Is there any way to control unique value during PUT method or any method to check if item already exists? Thanks

VictorKozachek

The code block below creates a new dict but fails when the file system does not allow file locks (or something else related to permissions). ```python def _get_queue_mapper_db_sesh() -> persistqueue.PDict:...

raokrutarth