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 933b754 commit 5ca377aCopy full SHA for 5ca377a
tests/conftest.py
@@ -1,6 +1,5 @@
1
import os
2
from typing import AsyncGenerator
3
-from uuid import uuid4
4
5
import pytest
6
from aiokafka import AIOKafkaConsumer, AIOKafkaProducer
tests/test_broker.py
@@ -45,7 +45,7 @@ async def test_kick_success(broker: AioKafkaBroker) -> None:
45
await broker.kick(message_to_send)
46
47
received_message_bytes: bytes = await asyncio.wait_for(
48
- get_first_task(broker),
+ get_first_task(broker),
49
timeout=1,
50
)
51
assert pickle.dumps(message_to_send) == received_message_bytes
0 commit comments