def wait_turrets(self, wait_for):
        print("waiting for {} turrets to connect".format(wait_for - len(self.turrets)))
        while len(self.turrets) < wait_for:
            self._publish({'command': 'status_request', 'msg': None})
            socks = dict(self.poller.poll(2000))
            if self.result_collector in socks:
                data = self.result_collector.recv_json()
                self._process_turret_status(data)
                print("waiting for {} turrets to connect".format(wait_for - len(self.turrets)))
Returns the current state.
dataset/ETHPy150Open TheGhouls/oct/oct/core/hq.py/HightQuarter.wait_turrets--crossover with--dataset/ETHPy150Open chop-dbhi/django-sts/sts/models.py/STSModel.current_state