args and envs

examples/dag.yaml

@@ -30,4 +30,4 @@ targets:
   sleep-and-echo:
     commands: |
       sleep 2
-      echo "Hi!"
+      echo "Hi from {{ id }}!"

pyproject.toml

@@ -22,6 +22,7 @@ classifiers = [
     "Programming Language :: Python :: 3 :: Only",
     "Programming Language :: Python :: 3.10",
     "Programming Language :: Python :: 3.11",
+    "Programming Language :: Python :: 3.12",
     "Topic :: Software Development",
     "Topic :: Utilities",
     "Typing :: Typed",
@@ -39,6 +40,8 @@ pyyaml = ">=6.0"
 networkx = ">=3.0"
 watchfiles = ">=0.18"
 identify = ">=2.5"
+jinja2 = ">=3.1"
+frozendict = ">=2.4"
 
 [tool.poetry.group.dev.dependencies]
 pre-commit = ">=3"

synthesize/cli.py

@@ -38,7 +38,7 @@ def run(
         help="The path to the configuration file to execute.",
     ),
     dry: bool = Option(
-        False,
+        default=False,
         help="If enabled, do not run actually run the flow.",
     ),
 ) -> None:
@@ -66,11 +66,25 @@ def run(
             )
         )
 
-        return
-
     resolved = parsed_config.resolve()
 
-    controller = Orchestrator(flow=resolved[flow], console=console)
+    try:
+        selected_flow = resolved[flow]
+    except KeyError:
+        sep = "\n  "
+        available_flows = sep + sep.join(resolved.keys())
+        console.print(
+            Text(
+                f"No flow named '{flow}'. Available flows:{available_flows}",
+                style=Style(color="red"),
+            )
+        )
+        raise Exit(code=1)
+
+    if dry:
+        return
+
+    controller = Orchestrator(flow=selected_flow, console=console)
 
     try:
         asyncio.run(controller.run())