Honor DAG task working directories

Author: Greyforge Admin

src/cortex-cli/src/dag_cmd/executor.rs

@@ -41,6 +41,11 @@ impl TaskExecutor {
             .get("command")
             .and_then(|v| v.as_str())
             .map(String::from);
+        let working_dir = task
+            .metadata
+            .get("working_dir")
+            .and_then(|v| v.as_str())
+            .map(String::from);
 
         if self.verbose {
             if let Some(ref cmd) = command {
@@ -55,7 +60,7 @@ impl TaskExecutor {
 
         // If there's a command, execute it
         let (status, output, error) = if let Some(cmd) = command {
-            match self.run_command(&cmd).await {
+            match self.run_command(&cmd, working_dir.as_deref()).await {
                 Ok(output) => (TaskStatus::Completed, Some(output), None),
                 Err(e) => (TaskStatus::Failed, None, Some(e.to_string())),
             }
@@ -80,14 +85,19 @@ impl TaskExecutor {
     }
 
     /// Run a shell command with timeout.
-    async fn run_command(&self, cmd: &str) -> Result<String> {
+    async fn run_command(&self, cmd: &str, working_dir: Option<&str>) -> Result<String> {
         let timeout_duration = self.timeout;
 
         let result = tokio::time::timeout(timeout_duration, async {
             let (shell, shell_arg) = shell_invocation();
-            let output = tokio::process::Command::new(shell)
-                .arg(shell_arg)
-                .arg(cmd)
+            let mut command = tokio::process::Command::new(shell);
+            command.arg(shell_arg).arg(cmd);
+
+            if let Some(dir) = working_dir {
+                command.current_dir(dir);
+            }
+
+            let output = command
                 .output()
                 .await
                 .context("Failed to execute command")?;

src/cortex-cli/src/dag_cmd/helpers.rs

@@ -65,6 +65,10 @@ pub fn convert_specs(input: &DagSpecInput) -> Vec<TaskSpec> {
                 spec = spec.with_metadata("command", serde_json::json!(cmd));
             }
 
+            if let Some(working_dir) = &t.working_dir {
+                spec = spec.with_metadata("working_dir", serde_json::json!(working_dir));
+            }
+
             for (key, value) in &t.metadata {
                 spec = spec.with_metadata(key, value.clone());
             }

src/cortex-cli/src/dag_cmd/tests.rs

@@ -41,6 +41,7 @@ fn test_convert_specs() {
                 name: "a".to_string(),
                 description: "Task A".to_string(),
                 command: Some("echo A".to_string()),
+                working_dir: None,
                 depends_on: vec![],
                 affected_files: vec![],
                 priority: 10,
@@ -51,6 +52,7 @@ fn test_convert_specs() {
                 name: "b".to_string(),
                 description: "Task B".to_string(),
                 command: None,
+                working_dir: None,
                 depends_on: vec!["a".to_string()],
                 affected_files: vec!["file.txt".to_string()],
                 priority: 5,

src/cortex-cli/src/dag_cmd/types.rs

@@ -56,6 +56,9 @@ pub struct TaskSpecInput {
     /// Command to execute (optional).
     #[serde(default)]
     pub command: Option<String>,
+    /// Working directory for command execution.
+    #[serde(default)]
+    pub working_dir: Option<String>,
     /// Task dependencies (names of tasks).
     #[serde(default)]
     pub depends_on: Vec<String>,