mirror of https://github.com/celery/kombu.git
pyflakes
This commit is contained in:
parent
f87f758956
commit
cab32ed427
|
@ -7,7 +7,7 @@
|
|||
settings_local.py
|
||||
.build
|
||||
build
|
||||
.*.sw[po]
|
||||
.*.sw[pon]
|
||||
dist/
|
||||
*.egg-info
|
||||
doc/__build/*
|
||||
|
|
|
@ -1,12 +1,8 @@
|
|||
from __future__ import absolute_import
|
||||
|
||||
import sys
|
||||
|
||||
from kombu.connection import BrokerConnection
|
||||
|
||||
from .utils import TestCase
|
||||
from .utils import mask_modules, Mock
|
||||
from .utils import Mock, skip_if_not_module
|
||||
from .utils import TestCase, skip_if_not_module
|
||||
|
||||
|
||||
class MockConnection(dict):
|
||||
|
|
|
@ -442,7 +442,6 @@ class test_Channel(TestCase):
|
|||
self.assertListEqual(channel.get_table('celery'),
|
||||
[('celery', '', 'celery')])
|
||||
|
||||
|
||||
# ... then for some reason, the _kombu.binding.celery key gets lost
|
||||
channel.client.srem(key)
|
||||
|
||||
|
|
|
@ -121,7 +121,9 @@ class Channel(virtual.Channel):
|
|||
|
||||
# At this point we expect the hostname to be something like
|
||||
# (considering replica set form too):
|
||||
# mongodb://[username:password@]host1[:port1][,host2[:port2],...[,hostN[:portN]]][/[?options]]
|
||||
#
|
||||
# mongodb://[username:password@]host1[:port1][,host2[:port2],
|
||||
# ...[,hostN[:portN]]][/[?options]]
|
||||
mongoconn = Connection(host=hostname)
|
||||
version = mongoconn.server_info()["version"]
|
||||
if tuple(map(int, version.split(".")[:2])) < (1, 3):
|
||||
|
|
Loading…
Reference in New Issue