async def METHOD_NAME(self):
    # First close down model updates loop
    for pid, worker in self._workers.items():
        await worker.stop()
        worker.join(self._settings.parallel_workers_timeout)
        if worker.exitcode is None:
            worker.kill()
        await asyncio.gather(
            *[callback(worker) for callback in self._on_worker_stop]
        )
    self._workers.clear()