automax-ci-generated-docs-sync.patch

Author: marcofortina

src/automax/plugins/transfer.py

@@ -20,6 +20,11 @@
 from automax.plugins.remote_utils import exec_remote, quote
 
 
+def _is_templated_path(value: str) -> bool:
+    """Return true when validation must wait until job rendering."""
+    return "{{" in value or "{%" in value or "{#" in value
+
+
 def _sftp(context: ExecutionContext):
     if context.ssh_client is None:
         raise RuntimeError("transfer plugin requires an SSH session")
@@ -133,7 +138,10 @@ class TransferUploadPlugin(BasePlugin):
 
     def validate(self, params: Dict[str, Any]) -> None:
         super().validate(params)
-        src = Path(str(params["src"])).expanduser()
+        src_value = str(params["src"])
+        if _is_templated_path(src_value):
+            return
+        src = Path(src_value).expanduser()
         if not src.exists():
             raise PluginValidationError(f"transfer.upload source not found: {src}")
         if src.is_dir() and not bool(params.get("recursive", False)):
@@ -243,7 +251,10 @@ class TransferSyncPlugin(BasePlugin):
 
     def validate(self, params: Dict[str, Any]) -> None:
         super().validate(params)
-        src = Path(str(params["src"])).expanduser()
+        src_value = str(params["src"])
+        if _is_templated_path(src_value):
+            return
+        src = Path(src_value).expanduser()
         if not src.is_dir():
             raise PluginValidationError("transfer.sync source must be a directory")
 

tests/test_next_engine.py

@@ -4269,6 +4269,12 @@ def test_cron_readback_plugins_render_manual_commands():
     assert "awk" in registry.get("cron.validate").manual_commands({"path": "/tmp/cron"}, context)[0]
 
 
+def test_transfer_plugins_allow_templated_controller_sources_in_static_validation():
+    from automax.plugins.transfer import TransferSyncPlugin, TransferUploadPlugin
+
+    TransferSyncPlugin().validate({"src": "{{ vars.fixture_root }}/source-dir", "dest": "/tmp/dest"})
+    TransferUploadPlugin().validate({"src": "{{ vars.fixture_root }}/source.txt", "dest": "/tmp/dest"})
+
 def test_transfer_upload_download_metadata_include_safety_options():
     from automax.plugins.registry import build_builtin_registry