From: Jiayong Li Date: Tue, 15 Nov 2016 19:59:55 +0000 (-0500) Subject: Merge master to output-tags branch and resolve conflict X-Git-Tag: 1.1.0~601^2 X-Git-Url: https://git.arvados.org/arvados.git/commitdiff_plain/c14246b9a21d038fc6fa850f4032659a98397784 Merge master to output-tags branch and resolve conflict --- c14246b9a21d038fc6fa850f4032659a98397784 diff --cc sdk/cwl/arvados_cwl/__init__.py index 6778eb0222,92be92d6e0..b3d47dd8d0 --- a/sdk/cwl/arvados_cwl/__init__.py +++ b/sdk/cwl/arvados_cwl/__init__.py @@@ -235,14 -248,13 +249,20 @@@ class ArvCwlRunner(object) final.api_response()["name"], final.manifest_locator()) + final_uuid = final.manifest_locator() + tags = tagsString.split(',') + for tag in tags: + self.api.links().create(body={ + "head_uuid": final_uuid, "link_class": "tag", "name": tag + }).execute(num_retries=self.num_retries) + - self.final_output_collection = final + def finalcollection(fileobj): + fileobj["location"] = "keep:%s/%s" % (final.portable_data_hash(), fileobj["location"]) + + adjustDirObjs(outputObj, finalcollection) + adjustFileObjs(outputObj, finalcollection) + + return (outputObj, final) def set_crunch_output(self): if self.work_api == "containers": @@@ -398,9 -410,7 +418,9 @@@ else: if self.output_name is None: self.output_name = "Output of %s" % (shortname(tool.tool["id"])) - self.final_output, self.final_output_collection = self.make_output_collection(self.output_name, self.final_output) + if self.output_tags is None: + self.output_tags = "" - self.make_output_collection(self.output_name, self.output_tags, self.final_output) ++ self.final_output, self.final_output_collection = self.make_output_collection(self.output_name, self.output_tags, self.final_output) self.set_crunch_output() if self.final_status != "success": diff --cc sdk/cwl/tests/test_make_output.py index a1cb605bfc,3228ad77b3..53f379f1a5 --- a/sdk/cwl/tests/test_make_output.py +++ b/sdk/cwl/tests/test_make_output.py @@@ -35,7 -32,7 +35,7 @@@ class TestMakeOutput(unittest.TestCase) final.open.return_value = openmock openmock.__enter__.return_value = cwlout - runner.make_output_collection("Test output", "tag0,tag1,tag2", { - _, runner.final_output_collection = runner.make_output_collection("Test output", { ++ _, runner.final_output_collection = runner.make_output_collection("Test output", "tag0,tag1,tag2", { "foo": { "class": "File", "location": "keep:99999999999999999999999999999991+99/foo.txt",