pymongo-job-queue

pymongo-job-queue copied to clipboard

Tried to fix the Travis tests, but looks like PyMongo 2.x cannot create a capped collection when running against a 3.x mongodb :-(

xverges

Adding test teardown to drop collection after each run.

accraze

Need to figure out how to unit test `JobQueue.__iter__`... see https://github.com/discogs/pymongo-job-queue/blob/master/pymjq/test.py#L50 Due to the cursor staying open and waiting for new documents to enter the queue, this method never returns...

accraze

AttributeError: 'Cursor' object has no attribute '_Cursor__id'

1

``` Traceback (most recent call last): File "Z:/spdaemon/app.py", line 184, in _runme message = self._jobqueue.next().get('data', None) File "Z:\Z_VirtualEnv\lib\site-packages\pymjq\jobqueue.py", line 42, in next tailable=True) File "Z:\Z_VirtualEnv\lib\site-packages\pymongo\collection.py", line 1137, in find return...

Smurf-IV

In `v2.0.0` it would be great if we introduced channels to the queue. You should be able to assign a worker to listen to a specific channel with full pub/sub...

accraze