We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent c3c763e commit 456893aCopy full SHA for 456893a
tests/asyncio_test.py
@@ -193,8 +193,7 @@ async def test_get_partitioned_topic_name(self):
193
producer = await self._client.create_producer("persistent://public/default/partitioned_topic_name_test")
194
await producer.send(b"hello")
195
196
- async with asyncio.timeout(TIMEOUT_MS / 1000):
197
- msg = await consumer.receive()
+ msg = await asyncio.wait_for(consumer.receive(), TIMEOUT_MS / 1000)
198
self.assertTrue(msg.topic_name() in partitions)
199
200
async def test_create_producer_failure(self):
0 commit comments