X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/20846db140dbba8a688718716e1e0f99ccfb3b51..606c29cdbb9012ee99043a2da9f28b2cd302e5e4:/sdk/cwl/tests/test_submit.py diff --git a/sdk/cwl/tests/test_submit.py b/sdk/cwl/tests/test_submit.py index 77bef075fa..f8b557f6cb 100644 --- a/sdk/cwl/tests/test_submit.py +++ b/sdk/cwl/tests/test_submit.py @@ -234,7 +234,6 @@ def stubs(func): }, 'secret_mounts': {}, 'state': 'Committed', - 'owner_uuid': None, 'command': ['arvados-cwl-runner', '--local', '--api=containers', '--no-log-timestamps', '--disable-validate', '--eval-timeout=20', '--thread-count=4', @@ -751,7 +750,6 @@ class TestSubmit(unittest.TestCase): 'kind': 'json' } }, 'state': 'Committed', - 'owner_uuid': None, 'output_path': '/var/spool/cwl', 'name': 'expect_arvworkflow.cwl#main', 'container_image': 'arvados/jobs:'+arvados_cwl.__version__, @@ -870,7 +868,6 @@ class TestSubmit(unittest.TestCase): 'kind': 'json' } }, 'state': 'Committed', - 'owner_uuid': None, 'output_path': '/var/spool/cwl', 'name': 'a test workflow', 'container_image': 'arvados/jobs:'+arvados_cwl.__version__, @@ -1236,7 +1233,6 @@ class TestSubmit(unittest.TestCase): }, "name": "secret_wf.cwl", "output_path": "/var/spool/cwl", - "owner_uuid": None, "priority": 500, "properties": {}, "runtime_constraints": { @@ -1259,6 +1255,31 @@ class TestSubmit(unittest.TestCase): self.assertEqual(capture_stdout.getvalue(), stubs.expect_container_request_uuid + '\n') + @stubs + def test_submit_request_uuid(self, stubs): + stubs.expect_container_request_uuid = "zzzzz-xvhdp-yyyyyyyyyyyyyyy" + + stubs.api.container_requests().update().execute.return_value = { + "uuid": stubs.expect_container_request_uuid, + "container_uuid": "zzzzz-dz642-zzzzzzzzzzzzzzz", + "state": "Queued" + } + + capture_stdout = cStringIO.StringIO() + try: + exited = arvados_cwl.main( + ["--submit", "--no-wait", "--api=containers", "--debug", "--submit-request-uuid=zzzzz-xvhdp-yyyyyyyyyyyyyyy", + "tests/wf/submit_wf.cwl", "tests/submit_test_job.json"], + capture_stdout, sys.stderr, api_client=stubs.api, keep_client=stubs.keep_client) + self.assertEqual(exited, 0) + except: + logging.exception("") + + stubs.api.container_requests().update.assert_called_with( + uuid="zzzzz-xvhdp-yyyyyyyyyyyyyyy", body=JsonDiffMatcher(stubs.expect_container_spec)) + self.assertEqual(capture_stdout.getvalue(), + stubs.expect_container_request_uuid + '\n') + class TestCreateTemplate(unittest.TestCase): existing_template_uuid = "zzzzz-d1hrv-validworkfloyml"