Rooba
/
kombu
mirror of https://github.com/celery/kombu.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

PEP8ify

This commit is contained in:
Ask Solem 2011-04-21 18:38:11 +02:00
parent a10c9ee44b
commit cfd12301ea
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
kombu/transport/mongodb.py
View File

@ -32,8 +32,9 @@ class Channel(virtual.Channel):
def _get(self, queue):
try:
msg = self.client.database.command("findandmodify",
"messages", query={"queue": queue}, sort={'_id' : pymongo.ASCENDING }, remove=True)
msg = self.client.database.command("findandmodify", "messages",
query={"queue": queue},
sort={"_id": pymongo.ASCENDING}, remove=True)
except errors.OperationFailure, exc:
if "No matching object found" in exc.args[0]:
raise Empty()