def wait_for_any_job()

in cstar/job.py [0:0]

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

    def wait_for_any_job(self):
        if self.do_loop:
            host, result = self.results.get(timeout=self.timeout)
            self.returned_jobs.append((host, result))
            while not self.results.empty():
                host, result = self.results.get(timeout=self.timeout)
                self.returned_jobs.append((host, result))
            self.handle_finished_jobs(self.returned_jobs)

            self.wait_for_node_to_return(returned_job[0] for returned_job in self.returned_jobs)
            self.returned_jobs = list()