From e4ef4835e59df0ef942798470c0f2cda574b327c Mon Sep 17 00:00:00 2001
From: Patrick Jentsch
Date: Mon, 3 Feb 2020 15:02:26 +0100
Subject: [PATCH] Add a switch for zip functionality
---
nlp | 13 +++++++++++--
1 file changed, 11 insertions(+), 2 deletions(-)
diff --git a/nlp b/nlp
index 7d6be3a..a8078a8 100755
--- a/nlp
+++ b/nlp
@@ -35,6 +35,14 @@ def parse_arguments():
help='total number of cores available',
required=False,
type=int)
+ parser.add_argument(
+ '--zip',
+ action='store_true',
+ default=False,
+ dest='zip',
+ help='package result files in zip bundles',
+ required=False
+ )
return parser.parse_args()
@@ -44,6 +52,7 @@ class NLPWorkflow(WorkflowRunner):
self.lang = args.lang
self.n_cores = args.n_cores
self.output_dir = args.output_dir
+ self.zip = args.zip
def workflow(self):
if len(self.jobs) == 0:
@@ -93,14 +102,14 @@ class NLPWorkflow(WorkflowRunner):
vrt_zip_jobs = []
vrt_zip_job_dependencies = nlp_jobs
- cmd = 'cd "%s" && zip vrt.zip */*.vrt -x "pyflow.data*" && cd -' % (
+ cmd = 'cd "%s" && zip -m vrt.zip */*.vrt -x "pyflow.data*" && cd -' % (
self.output_dir
)
vrt_zip_jobs.append(
self.addTask(
command=cmd,
dependencies=vrt_zip_job_dependencies,
- label='vrt_zip_job_-_%i' % (index)
+ label='vrt_zip_job'
)
)