Make bulk run bullet proof

This commit is contained in:
henryruhs 2024-11-11 22:03:20 +01:00
parent 70245be5de
commit f3ab515f09

View File

@ -324,7 +324,8 @@ def process_bulk(args : Args) -> ErrorCode:
step_args['source_paths'] = [ source_path ]
step_args['target_path'] = target_path
step_args['output_path'] = job_args.get('output_pattern').format(index = index)
job_manager.add_step(job_id, step_args)
if not job_manager.add_step(job_id, step_args):
return 1
if job_manager.submit_job(job_id) and job_runner.run_job(job_id, process_step):
return 0