diff options
| author | Ask Solem <ask@celeryproject.org> | 2015-12-10 13:21:33 -0800 |
|---|---|---|
| committer | Ask Solem <ask@celeryproject.org> | 2015-12-10 13:21:50 -0800 |
| commit | 755e6fc59e04e151db4769c8654b853c694404df (patch) | |
| tree | 5e29d96d8d7b0bc6152de18aad356271dc15c95d | |
| parent | de3f17a4e6c8bb020993fea169e1b8b1ea1e221f (diff) | |
| download | kombu-755e6fc59e04e151db4769c8654b853c694404df.tar.gz | |
Fixes build
| -rw-r--r-- | kombu/tests/transport/test_redis.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/kombu/tests/transport/test_redis.py b/kombu/tests/transport/test_redis.py index ae79d527..5d6472c5 100644 --- a/kombu/tests/transport/test_redis.py +++ b/kombu/tests/transport/test_redis.py @@ -205,7 +205,7 @@ class Channel(redis.Channel): def _get_client(self): return Client - def _get_pool(self): + def _get_pool(self, async=False): return Mock() def _get_response_error(self): @@ -302,9 +302,9 @@ class test_Channel(Case): self.channel._pool = None self.channel._after_fork() - self.channel._pool = Mock(name='pool') + pool = self.channel._pool = Mock(name='pool') self.channel._after_fork() - self.channel._pool.disconnect.assert_called_with() + pool.disconnect.assert_called_with() def test_next_delivery_tag(self): self.assertNotEqual( |