fix tag path bug in slurm for job array (#160)

Author: njzjz

dpdispatcher/slurm.py

@@ -239,6 +239,6 @@ def check_status(self, job, retry=0, max_retry=3):
     def check_finish_tag(self, job):
         results = []
         for task in job.job_task_list:
-            task_tag_finished = task.task_hash + '_task_tag_finished'
+            task_tag_finished = (pathlib.PurePath(task.task_work_path)/(task.task_hash + '_task_tag_finished')).as_posix()
             results.append(self.context.check_file_exists(task_tag_finished))
         return all(results)