def __call__()

in cstar/jobrunner.py [0:0]

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

    def __call__(self):
        with cstar.remote.Remote(self.host, self.ssh_username, self.ssh_password, self.ssh_identity_file, self.ssh_lib, self.host_variables) as conn:
            result = conn.run_job(self.job.command, self.job.job_id, self.job.timeout, self.job.env)
            self.job.results.put((self.host, result))  # This signals the main thread that the job completed.
            save_output(self.job, self.host, result)
            # We have to make sure that the local job file is updated before the remote
            # job data is deleted. We need to syncronize with the main thread.
            while self.host not in self.job.handled_finished_jobs:
                time.sleep(1)
            conn.run(("rm", "-rf", ".cstar/remote-jobs/" + self.job.job_id))
        return result