if new_res:
return "completed"
else:
return "completed-old"
else:
env.logger.debug("{} not found or signature mismatch".format(res["output"]))
if new_res:
return "failed-missing-output"
After Change
return check_task(task)
try:
if not os.path.isfile(status_file) or os.path.getmtime(status_file) < os.path.getmtime(task_file):
if os.path.isfile(job_file) and os.path.getmtime(job_file) >= os.path.getmtime(task_file):
return "submitted"
else:
return "pending"