X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/55ed403e8bd408c70ce97cefc10156141ccd46a6..d65963976174bd9c94fdb0b91eeb8a281f01e7b3:/crunch_scripts/run-command diff --git a/crunch_scripts/run-command b/crunch_scripts/run-command index 1635ecdf69..c5fbcdfc02 100755 --- a/crunch_scripts/run-command +++ b/crunch_scripts/run-command @@ -173,12 +173,12 @@ try: logger.info("{}{}{}".format(' '.join(cmd), (" < " + stdinname) if stdinname is not None else "", (" > " + stdoutname) if stdoutname is not None else "")) except subst.SubstitutionError as e: logger.error(str(e)) - logger.error("task parameters was:") + logger.error("task parameters were:") logger.error(pprint.pformat(taskp)) sys.exit(1) except Exception as e: logger.exception("caught exception") - logger.error("task parameters was:") + logger.error("task parameters were:") logger.error(pprint.pformat(taskp)) sys.exit(1) @@ -225,7 +225,7 @@ if "task.vwd" in taskp: # Just a single task, so do merge with the original collection outcollection = vwd.checkin(subst.do_substitution(taskp, taskp["task.vwd"]), outdir, merge=True).manifest_text() else: - outcollection = robust_put.upload(outdir) + outcollection = robust_put.upload(outdir, logger) api.job_tasks().update(uuid=arvados.current_task()['uuid'], body={