this repo has no description
fix missing await
+2
-2
+2
-2
src/atkafka_consumer/consumer.py
+2
-2
src/atkafka_consumer/consumer.py
···
51
51
assert self._semaphore
52
52
53
53
if self._ozone_mode:
54
-
return self._handle_ozone_event(message)
54
+
await self._handle_ozone_event(message)
55
55
else:
56
-
return self._handle_base_event(message)
56
+
await self._handle_base_event(message)
57
57
58
58
async def _handle_base_event(self, message: ConsumerRecord[Any, Any]):
59
59
assert self._semaphore