X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/287a03d273629ef15f77721ad2c7ce572fb5c078..21bf21abe900918a7882f7e43c102418e04159be:/sdk/cwl/tests/test_make_output.py diff --git a/sdk/cwl/tests/test_make_output.py b/sdk/cwl/tests/test_make_output.py index 3228ad77b3..590c82d207 100644 --- a/sdk/cwl/tests/test_make_output.py +++ b/sdk/cwl/tests/test_make_output.py @@ -1,3 +1,7 @@ +# Copyright (C) The Arvados Authors. All rights reserved. +# +# SPDX-License-Identifier: Apache-2.0 + import functools import json import logging @@ -27,12 +31,15 @@ class TestMakeOutput(unittest.TestCase): readermock = mock.MagicMock() reader.return_value = readermock + final_uuid = final.manifest_locator() + num_retries = runner.num_retries + cwlout = StringIO.StringIO() openmock = mock.MagicMock() final.open.return_value = openmock openmock.__enter__.return_value = cwlout - _, runner.final_output_collection = runner.make_output_collection("Test output", { + _, runner.final_output_collection = runner.make_output_collection("Test output", ["foo"], "tag0,tag1,tag2", { "foo": { "class": "File", "location": "keep:99999999999999999999999999999991+99/foo.txt", @@ -49,14 +56,16 @@ class TestMakeOutput(unittest.TestCase): final.copy.assert_has_calls([mock.call('bar.txt', 'baz.txt', overwrite=False, source_collection=readermock)]) final.copy.assert_has_calls([mock.call('foo.txt', 'foo.txt', overwrite=False, source_collection=readermock)]) - final.save_new.assert_has_calls([mock.call(ensure_unique_name=True, name='Test output', owner_uuid='zzzzz-j7d0g-zzzzzzzzzzzzzzz')]) + final.save_new.assert_has_calls([mock.call(ensure_unique_name=True, name='Test output', owner_uuid='zzzzz-j7d0g-zzzzzzzzzzzzzzz', storage_classes=['foo'])]) self.assertEqual("""{ "bar": { + "basename": "baz.txt", "class": "File", "location": "baz.txt", "size": 4 }, "foo": { + "basename": "foo.txt", "class": "File", "location": "foo.txt", "size": 3 @@ -64,3 +73,7 @@ class TestMakeOutput(unittest.TestCase): }""", cwlout.getvalue()) self.assertIs(final, runner.final_output_collection) + self.assertIs(final_uuid, runner.final_output_collection.manifest_locator()) + self.api.links().create.assert_has_calls([mock.call(body={"head_uuid": final_uuid, "link_class": "tag", "name": "tag0"}), mock.call().execute(num_retries=num_retries)]) + self.api.links().create.assert_has_calls([mock.call(body={"head_uuid": final_uuid, "link_class": "tag", "name": "tag1"}), mock.call().execute(num_retries=num_retries)]) + self.api.links().create.assert_has_calls([mock.call(body={"head_uuid": final_uuid, "link_class": "tag", "name": "tag2"}), mock.call().execute(num_retries=num_retries)])