We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1cad32a commit c5a6c63Copy full SHA for c5a6c63
test/test_producer.py
@@ -2,6 +2,10 @@
2
3
import logging
4
5
+try:
6
+ from queue import Full
7
+except ImportError:
8
+ from Queue import Full
9
from mock import MagicMock
10
from multiprocessing.queues import Full
11
from . import unittest
@@ -82,4 +86,4 @@ def test_producer_async_queue_normal(self):
82
86
resp = producer.send_messages(topic, partition, *message_list)
83
87
self.assertEqual(type(resp), list)
84
88
self.assertEqual(producer.queue.qsize(), acceptable_size)
85
- self.assertEqual(producer.queue.full(), False)
89
+ self.assertFalse(producer.queue.full())
0 commit comments