Clean up asyncio calls in app/consumer