X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/d48af5cfd486b9ea93b57c7f88b80e0305664b0b..92ce0b4ffb51c957ddc0a6e36f7dfba2c819b38f:/sdk/cwl/tests/test_job.py diff --git a/sdk/cwl/tests/test_job.py b/sdk/cwl/tests/test_job.py index bb15e60f1f..dba65b0f8a 100644 --- a/sdk/cwl/tests/test_job.py +++ b/sdk/cwl/tests/test_job.py @@ -1,6 +1,14 @@ -import unittest -import mock import arvados_cwl +import logging +import mock +import unittest +import os +import cwltool.process + +if not os.getenv('ARVADOS_DEBUG'): + logging.getLogger('arvados.cwl-runner').setLevel(logging.WARN) + logging.getLogger('arvados.arv-run').setLevel(logging.WARN) + class TestJob(unittest.TestCase): @@ -10,15 +18,16 @@ class TestJob(unittest.TestCase): runner = mock.MagicMock() runner.project_uuid = "zzzzz-8i9sb-zzzzzzzzzzzzzzz" runner.ignore_docker_for_reuse = False + document_loader, avsc_names, schema_metadata, metaschema_loader = cwltool.process.get_schema("draft-3") tool = { "inputs": [], "outputs": [], "baseCommand": "ls" } - arvtool = arvados_cwl.ArvadosCommandTool(runner, tool) + arvtool = arvados_cwl.ArvadosCommandTool(runner, tool, avsc_names=avsc_names, basedir="") arvtool.formatgraph = None - for j in arvtool.job({}, "", mock.MagicMock()): + for j in arvtool.job({}, mock.MagicMock(), basedir=""): j.run() runner.api.jobs().create.assert_called_with( body={ @@ -28,9 +37,9 @@ class TestJob(unittest.TestCase): 'tasks': [{ 'task.env': {'TMPDIR': '$(task.tmpdir)'}, 'command': ['ls'] - }] - }, - 'script_version': 'master', + }], + }, + 'script_version': 'master', 'minimum_script_version': '9e5b98e8f5f4727856b53447191f9c06e3da2ba6', 'repository': 'arvados', 'script': 'crunchrunner', @@ -40,8 +49,8 @@ class TestJob(unittest.TestCase): 'min_ram_mb_per_node': 1024, 'min_scratch_mb_per_node': 2048 # tmpdirSize + outdirSize } - }, - find_or_create=True, + }, + find_or_create=True, filters=[['repository', '=', 'arvados'], ['script', '=', 'crunchrunner'], ['script_version', 'in git', '9e5b98e8f5f4727856b53447191f9c06e3da2ba6'], @@ -54,6 +63,7 @@ class TestJob(unittest.TestCase): runner = mock.MagicMock() runner.project_uuid = "zzzzz-8i9sb-zzzzzzzzzzzzzzz" runner.ignore_docker_for_reuse = False + document_loader, avsc_names, schema_metadata, metaschema_loader = cwltool.process.get_schema("draft-3") tool = { "inputs": [], @@ -66,9 +76,9 @@ class TestJob(unittest.TestCase): }], "baseCommand": "ls" } - arvtool = arvados_cwl.ArvadosCommandTool(runner, tool) + arvtool = arvados_cwl.ArvadosCommandTool(runner, tool, avsc_names=avsc_names) arvtool.formatgraph = None - for j in arvtool.job({}, "", mock.MagicMock()): + for j in arvtool.job({}, mock.MagicMock(), basedir=""): j.run() runner.api.jobs().create.assert_called_with( body={ @@ -90,7 +100,7 @@ class TestJob(unittest.TestCase): 'min_ram_mb_per_node': 3000, 'min_scratch_mb_per_node': 5024 # tmpdirSize + outdirSize } - }, + }, find_or_create=True, filters=[['repository', '=', 'arvados'], ['script', '=', 'crunchrunner'],