// 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(
