summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAsk Solem <ask@celeryproject.org>2016-12-07 15:18:23 -0800
committerAsk Solem <ask@celeryproject.org>2016-12-07 15:18:23 -0800
commite707bd24ee2cadd989e500979eb2f7b3da9e2f05 (patch)
treec9fe63a1db985f3e51c3f908c9d44e085422d531
parent8a7ea091bfcce802f136b3bfef28a562a3962a81 (diff)
downloadkombu-e707bd24ee2cadd989e500979eb2f7b3da9e2f05.tar.gz
MongoDB: Do not use basestring for Py3 compat. Closes #661
-rw-r--r--kombu/transport/mongodb.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/kombu/transport/mongodb.py b/kombu/transport/mongodb.py
index f6ca8c7c..2e32e048 100644
--- a/kombu/transport/mongodb.py
+++ b/kombu/transport/mongodb.py
@@ -13,7 +13,7 @@ from pymongo import MongoClient, uri_parser
from pymongo.cursor import CursorType
from kombu.exceptions import VersionMismatch
-from kombu.five import Empty
+from kombu.five import Empty, string_t
from kombu.utils.compat import _detect_environment
from kombu.utils.encoding import bytes_to_str
from kombu.utils.json import loads, dumps
@@ -398,7 +398,7 @@ class Channel(virtual.Channel):
Note:
`queue` must be either queue name or options itself.
"""
- if isinstance(queue, basestring):
+ if isinstance(queue, string_t):
doc = self.queues.find_one({'_id': queue})
if not doc: