def wait_for_hadoop()

in src/smspark/bootstrapper.py [0:0]

• 11 lines of code
• 2 McCabe index (conditional complexity)

    def wait_for_hadoop(self) -> None:
        def cluster_is_up() -> bool:
            cluster_info_url = "http://{}:8042/node".format(self.resource_config["current_host"])
            try:
                resp = requests.get(cluster_info_url)
                return resp.ok
            except Exception:
                return False

        self.logger.info("waiting for cluster to be up")
        self.waiter.wait_for(predicate_fn=cluster_is_up, timeout=60.0, period=1.0)
        self.logger.info("cluster is up")