parser = argparse.ArgumentParser()
parser.add_argument('--dry-run', action='store_true')
-parser.add_argument('--job-parameters', type=str, default="{}")
+parser.add_argument('--script-parameters', type=str, default="{}")
args = parser.parse_args()
os.umask(0077)
jobp = json.loads(args.job_parameters)
os.environ['JOB_UUID'] = 'zzzzz-8i9sb-1234567890abcde'
os.environ['TASK_UUID'] = 'zzzzz-ot0gb-1234567890abcde'
- os.environ['CRUNCH_SRC'] = '/tmp/crunch-src'
- os.environ['TASK_KEEPMOUNT'] = '/keep'
+ os.environ['CRUNCH_SRC'] = '/tmp/crunche-src'
+ if 'TASK_KEEPMOUNT' not in os.environ:
+ os.environ['TASK_KEEPMOUNT'] = '/keep'
links = []
self.sig = signum
def add_to_group(gr, match):
- m = ('^_^').join(match.groups())
+ m = match.groups()
if m not in gr:
gr[m] = []
gr[m].append(match.group(0))
items = get_items(p, p[c["group"]])
groups = {}
for i in items:
- p = pattern.match(i)
- if p:
- add_to_group(groups, p)
+ match = pattern.match(i)
+ if match:
+ add_to_group(groups, match)
return [groups[k] for k in groups]
elif "extract" in c:
items = get_items(p, p[c["extract"]])
r = []
for i in items:
- p = pattern.match(i)
- if p:
- r.append(list(p.groups()))
+ match = pattern.match(i)
+ if match:
+ r.append(list(match.groups()))
return r
elif isinstance(c, list):
return expand_list(p, c)