Open
Description
in sender.py except Exception: # pragma: no cover log.error("Unexpected error in sender routine", exc_info=True) if self._on_irrecoverable_error: res = self._on_irrecoverable_error(exc) if asyncio.iscoroutine(res): # callback can be async def yield from res raise KafkaError("Unexpected error during batch delivery")
exc is not defined!
Metadata
Metadata
Assignees
Labels
No labels