gate task execution

crates/turborepo-lib/src/run/mod.rs

@@ -487,7 +487,8 @@ impl<'a> Run<'a> {
             true,
             self.processes.clone(),
             &self.base.repo_root,
-        );
+        )
+        .dry_run();
 
         visitor.visit(engine.clone()).await?;
         let task_hash_tracker = visitor.into_task_hash_tracker();

crates/turborepo-lib/src/task_graph/visitor.rs

@@ -42,6 +42,7 @@ pub struct Visitor<'a> {
     ui: UI,
     manager: ProcessManager,
     repo_root: &'a AbsoluteSystemPath,
+    dry: bool,
 }
 
 #[derive(Debug, thiserror::Error)]
@@ -101,6 +102,7 @@ impl<'a> Visitor<'a> {
             ui,
             manager,
             repo_root,
+            dry: false,
         }
     }
 
@@ -180,6 +182,10 @@ impl<'a> Visitor<'a> {
             )?;
 
             debug!("task {} hash is {}", info, task_hash);
+            if self.dry {
+                callback.send(Ok(())).ok();
+                continue;
+            }
 
             let task_cache =
                 self.run_cache
@@ -387,6 +393,11 @@ impl<'a> Visitor<'a> {
     pub fn into_task_hash_tracker(self) -> TaskHashTrackerState {
         self.task_hasher.into_task_hash_tracker_state()
     }
+
+    pub fn dry_run(mut self) -> Self {
+        self.dry = true;
+        self
+    }
 }
 
 // A tiny enum that allows us to use the same type for stdout and stderr without