2ad24c0af410a6021584b45c76ef96973a5a4475,sos/PBS/sos_task.py,PBS_TaskEngine,query_tasks,#PBS_TaskEngine#Any#Any#,127

Before Change

            // call query_tasks again for more verbose output
            res += super(PBS_TaskEngine, self).query_tasks([task_id], verbosity) + "\n"
            //
            job_id_file = os.path.join(os.path.expanduser("~"), ".sos", "tasks", self.alias, task_id + ".job_id")
            if not os.path.isfile(job_id_file):
                continue
            with open(job_id_file) as job:
                job_id = job.read().strip()
            try:
                cmd = interpolate(self.status_cmd, "${ }", {"task": task_id, "job_id": job_id, "verbosity": verbosity})
                res += self.agent.check_output(cmd)
            except Exception as e:

After Change

            if not job_id:
                continue
            try:
                job_id.update({"task": task_id, "verbosity": verbosity})
                cmd = interpolate(self.status_cmd, "${ }", job_id)
                res += self.agent.check_output(cmd)
            except Exception as e:
                env.logger.debug("Failed to get status of task {} (job_id: {}) from template "{}": {}".format(

Instances