async def METHOD_NAME(self):
    """Start and monitor the coalescer
    """
    try:
        await self._monitor_coalescer()
    except asyncio.CancelledError:
        pass
    finally:
        # If the coalescer is still runnning we always need to terminate
        # it before exiting
        if self.coalescer_process and \
           self.coalescer_process.returncode is None:
            self.coalescer_process.terminate()
            try:
                logger.warning('Waiting coalescer termination...')
                await asyncio.wait_for(self.coalescer_process.wait(), 10)
            except asyncio.TimeoutError:
                self.coalescer_process.kill()