Skip to content
Snippets Groups Projects
Commit 8340677c authored by Jorrit Schaap's avatar Jorrit Schaap
Browse files

SW-699: group jobs per job_group_id in all status-folders

parent 607868aa
No related branches found
No related tags found
No related merge requests found
......@@ -214,14 +214,12 @@ class IngestJobManager:
retry_attempt=job_admin_dict.get('retry_attempt', 1))
base_dir = self.jobStatusBaseDir(job_status)
group_dir = '%s_%s' % (job_type, job_group_id)
if job_status == JobRetry and retry_attempt != None:
return os.path.join(base_dir, str(retry_attempt))
elif job_status in [JobProduced, JobRemoved, JobFailed]:
group_dir = '%s_%s' % (job_type, job_group_id)
return os.path.join(base_dir, group_dir)
return os.path.join(base_dir, group_dir, str(retry_attempt))
return base_dir
return os.path.join(base_dir, group_dir)
def jobPath(self, job_admin_dict):
dir = self.jobDir(job_admin_dict)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment