def connection_lost(self, exc):
        """
        Called when the connection to the remote worker is broken. Closes the
        worker.
        """

        logger.debug("worker connection lost")

        self._worker.close()
        self._workers.remove(self._worker)
Called when the connection to the remote worker is broken. Closes the
        worker.