def notConnected(self, msg):
        """I can't connect to a publisher; I'll now reply to all pending
        requests.
        """
        self._log.info(
            "could not connect to distributed web service: {msg}",
            msg=msg
        )
        self.waiting = 0
        self.publisher = None
        for request in self.pending:
            request.write("Unable to connect to distributed server.")
            request.finish()
        self.pending = []
I can't connect to a publisher; I'll now reply to all pending
        requests.
        
stackoverflow/venv/lib/python3.6/site-packages/twisted/web/distrib.py