diff --git a/pkg/processor/runtime/python/py/_nuclio_async_wrapper.py b/pkg/processor/runtime/python/py/_nuclio_async_wrapper.py index eac8e28895..62e29542ce 100644 --- a/pkg/processor/runtime/python/py/_nuclio_async_wrapper.py +++ b/pkg/processor/runtime/python/py/_nuclio_async_wrapper.py @@ -147,9 +147,8 @@ async def _process_connection(self, sock): self._context.logger = connection_logger # signal start - self._logger.debug("Signalling connection processing start") await self._write_packet_to_processor(sock, 's') - self._logger.debug(f"Event processing started for socket") + try: while True: # resolve event message length