def wait_for_node_to_return()

in cstar/job.py [0:0]

• 12 lines of code
• 4 McCabe index (conditional complexity)

    def wait_for_node_to_return(self, nodes=()):
        """Wait until node returns"""
        while True:
            try:
                self.update_current_topology(nodes)

                if self.state.is_healthy():
                    break
            except BadSSHHost as e:
                # If the instance used to poll cluster health is down it probably means that machine is rebooting
                # State is then NOT healthy, so continue waiting...
                debug("SSH to %s failed, instance down?" % (node, ), e)
            cstar.jobprinter.print_progress(self.state.original_topology,
                                            self.state.progress,
                                            self.state.current_topology.get_down())
            time.sleep(5)