Faust agent hangs without any error. Can't figure out what is the issue

Question

I am using faust and asyncio to process mt kafka stream. I am also using aiomysql to create connection pool. When I start the worker, it process the messages from the stream but hangs after processing some of them. There are no error messages in the logs. Other tasks are running in the worker like some cron jobs. But the agent stops processing any further messages.