diff options
author | Ask Solem <ask@celeryproject.org> | 2016-12-07 15:18:23 -0800 |
---|---|---|
committer | Ask Solem <ask@celeryproject.org> | 2016-12-07 15:18:23 -0800 |
commit | e707bd24ee2cadd989e500979eb2f7b3da9e2f05 (patch) | |
tree | c9fe63a1db985f3e51c3f908c9d44e085422d531 | |
parent | 8a7ea091bfcce802f136b3bfef28a562a3962a81 (diff) | |
download | kombu-e707bd24ee2cadd989e500979eb2f7b3da9e2f05.tar.gz |
MongoDB: Do not use basestring for Py3 compat. Closes #661
-rw-r--r-- | kombu/transport/mongodb.py | 4 |
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: |