Skip EnsureRenderedStringPattern preprocessor if parameter has verbatim directives

boundary_layer_default_plugin/preprocessors.py

@@ -110,15 +110,23 @@ def process_arg(self, arg, node, raw_args):
                 regex.pattern)
             return arg
 
-        if not regex.match(rendered_arg):
-            raise Exception(
-                'Invalid argument `{}`: does not match expected pattern `{}`'.format(
-                    rendered_arg,
-                    regex.pattern))
+        if regex.match(rendered_arg):
+            # return the original arg, not the rendered arg, because we are not
+            # actually transforming anything, just validating
+            return arg
+
+        VERBATIM_REGEX = '<<.+>>'
+        if re.compile(VERBATIM_REGEX).search(rendered_arg):
+            logger.warning(
+                'Argument generated from `%s` may not match the required pattern `%s` and fail.',
+                rendered_arg,
+                regex.pattern)
+            return arg
 
-        # return the original arg, not the rendered arg, because we are not
-        # actually transforming anything, just validating
-        return arg
+        raise Exception(
+            'Invalid argument `{}`: does not match expected pattern `{}`'.format(
+                rendered_arg,
+                regex.pattern))
 
     @property
     def pattern(self):

test/default_plugin/test_preprocessors.py

@@ -32,6 +32,21 @@ def test_ensure_rendered_string_pattern(mocker):
     ) == "my-cluster-{{unknown_var.task_id}}"
     warning_mock.assert_called_once()
 
+
+    warning_mock = Mock()
+    mocker.patch.object(logger, 'warning', new=warning_mock)
+    assert renderer.process_arg(
+        "my-<<item_name>>-cluster", None, {},
+    ) == "my-<<item_name>>-cluster"
+    warning_mock.assert_called_once()
+
+    warning_mock = Mock()
+    mocker.patch.object(logger, 'warning', new=warning_mock)
+    assert renderer.process_arg(
+        "my-cluster-<<item.value>>", None, {},
+    ) == "my-cluster-<<item.value>>"
+    warning_mock.assert_called_once()
+
     with pytest.raises(Exception):
         renderer.process_arg("my-cluster-", None, {})
 
@@ -46,3 +61,6 @@ def test_ensure_rendered_string_pattern(mocker):
             "my-cluster-{{execution_date.strftime('%Y_%m_%d')}}",
             None,
             {})
+
+    with pytest.raises(Exception):
+        renderer.process_arg("My-<item.value>-cluster", None, {})