if err != nil {
t.Fatalf("got error %s", err)
}
- if matched, err := regexp.MatchString("^package crunchstat\n", string(data)); err != nil || !matched {
+ if matched, err := regexp.MatchString("\npackage crunchstat\n", string(data)); err != nil || !matched {
t.Fatalf("data failed regexp: err %v, matched %v", err, matched)
}
}
import difflib
import json
+import re
class JsonDiffMatcher(object):
actual_json.splitlines(1),
fromfile="Expected", tofile="Actual")))
return True
+
+
+def StripYAMLComments(yml):
+ return re.sub(r'(?ms)^(#.*?\n)*\n*', '', yml)
from schema_salad.ref_resolver import Loader
from schema_salad.sourceline import cmap
from .mock_discovery import get_rootDesc
-from .matcher import JsonDiffMatcher
+from .matcher import JsonDiffMatcher, StripYAMLComments
if not os.getenv('ARVADOS_DEBUG'):
logging.getLogger('arvados.cwl-runner').setLevel(logging.WARN)
it.next().run()
with open("tests/wf/scatter2_subwf.cwl") as f:
- subwf = f.read()
+ subwf = StripYAMLComments(f.read())
runner.api.jobs().create.assert_called_with(
body=JsonDiffMatcher({
import arvados_cwl.runner
import arvados.keep
-from .matcher import JsonDiffMatcher
+from .matcher import JsonDiffMatcher, StripYAMLComments
from .mock_discovery import get_rootDesc
import ruamel.yaml as yaml
class TestCreateWorkflow(unittest.TestCase):
existing_workflow_uuid = "zzzzz-7fd4e-validworkfloyml"
- expect_workflow = open("tests/wf/expect_packed.cwl").read()
+ expect_workflow = StripYAMLComments(
+ open("tests/wf/expect_packed.cwl").read())
@stubs
def test_create(self, stubs):
capture_stdout, sys.stderr, api_client=stubs.api)
self.assertEqual(exited, 0)
- expect_workflow = open("tests/collection_per_tool/collection_per_tool_packed.cwl").read()
+ toolfile = "tests/collection_per_tool/collection_per_tool_packed.cwl"
+ expect_workflow = StripYAMLComments(open(toolfile).read())
body = {
"workflow": {