From 22a7217036933ff14b277a8e53274e222d204aea Mon Sep 17 00:00:00 2001
From: Patrick Jentsch
Date: Tue, 18 Jan 2022 13:45:03 +0100
Subject: [PATCH] fix output_records.json generation
---
file-setup | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git a/file-setup b/file-setup
index 83ee94d..7d14b9b 100755
--- a/file-setup
+++ b/file-setup
@@ -66,7 +66,6 @@ class MainWorkflow(WorkflowRunner):
self.input_dir = input_dir
self.output_dir = output_dir
self.jobs = []
- self.collect_jobs()
def collect_jobs(self):
for dir in os.listdir(self.input_dir):
@@ -103,10 +102,11 @@ class MainWorkflow(WorkflowRunner):
create_pdf_tasks.append(task)
self.waitForTasks()
+ output_files = []
for job in self.jobs:
# Track output files
relative_output_dir = os.path.relpath(job.output_dir, start=self.output_dir) # noqa
- self.output_files.append(
+ output_files.append(
{
'description': 'PDF file without text layer.',
'file': os.path.join(relative_output_dir, '{}.pdf'.format(job.name)), # noqa
@@ -114,7 +114,7 @@ class MainWorkflow(WorkflowRunner):
}
)
with open(os.path.join(self.output_dir, 'output_records.json'), 'w') as f: # noqa
- json.dump(self.output_files, f, indent=4)
+ json.dump(output_files, f, indent=4)
def parse_args():
@@ -160,6 +160,7 @@ def parse_args():
def main():
args = parse_args()
main_workflow = MainWorkflow(args.input_dir, args.output_dir)
+ main_workflow.collect_jobs()
retval = main_workflow.run(
dataDirRoot=args.log_dir, memMb=args.mem_mb, nCores=args.n_cores) # noqa
sys.exit(retval)