def expand_item(p, c):
if isinstance(c, dict):
if "foreach" in c and "command" in c:
+ # Expand a command template for each item in the specified user
+ # parameter
var, items = var_items(p, c, "foreach")
if var is None:
raise EvaluationError("Must specify 'var' in foreach")
r.append(expand_item(params, c["command"]))
return r
elif "list" in c and "index" in c and "command" in c:
+ # extract a single item from a list
var, items = var_items(p, c, "list")
if var is None:
raise EvaluationError("Must specify 'var' in list")
elif "regex" in c:
pattern = re.compile(c["regex"])
if "filter" in c:
+ # filter list so that it only includes items that match a
+ # regular expression
_, items = var_items(p, c, "filter")
return [i for i in items if pattern.match(i)]
elif "group" in c:
+ # generate a list of lists, where items are grouped on common
+ # subexpression match
_, items = var_items(p, c, "group")
groups = {}
for i in items:
add_to_group(groups, match)
return [groups[k] for k in groups]
elif "extract" in c:
+ # generate a list of lists, where items are split by
+ # subexpression match
_, items = var_items(p, c, "extract")
r = []
for i in items:
r.append(list(match.groups()))
return r
elif "batch" in c and "size" in c:
+ # generate a list of lists, where items are split into a batch size
_, items = var_items(p, c, "batch")
sz = int(c["size"])
r = []
return expand_item(p, p[m.group(1)])
else:
return subst.do_substitution(p, c)
-
- raise EvaluationError("expand_item() unexpected parameter type %s" % (type(c))
+ else:
+ raise EvaluationError("expand_item() unexpected parameter type %s" % type(c))
# Evaluate in a list context
# "p" is the parameter scope, "value" will be evaluated
logger.error(pprint.pformat(taskp))
sys.exit(1)
+# rcode holds the return codes produced by each subprocess
+rcode = {}
try:
subprocesses = []
close_streams = []
active = 1
pids = set([s.pid for s in subprocesses])
- rcode = {}
while len(pids) > 0:
(pid, status) = os.wait()
pids.discard(pid)
outcollection = robust_put.upload(outdir, logger)
# Success if no non-zero return codes
-success = not any([status != 0 for status in rcode.values()])
+success = any(rcode) and not any([status != 0 for status in rcode.values()])
api.job_tasks().update(uuid=arvados.current_task()['uuid'],
body={