try

.github/actions/mounts/action.yml

@@ -29,7 +29,7 @@ runs:
           const cache = require('@actions/cache');
           const data = ${{ toJSON(fromJSON(steps.dependencies.outputs.data)) }};
           // Make actions/cache's getWorkingDirectory() return process.cwd.
-          delete process.env.GITHUB_GITHUB_WORKSPACE;
+          delete process.env.GITHUB_WORKSPACE;
           for (const mount of data) {
             const dir = path.join('cache', mount.key, path.dirname(mount.artifact));
             fs.mkdirSync(dir, { recursive: true });

.github/actions/task/action.yml

@@ -38,5 +38,4 @@ runs:
       shell: bash
 #      if: ${{ steps.cache.outputs.cache-hit != 'true' }}
       run: | 
-        find . -ls
-        python3 CI/run.py --cache cache --out . "${{ inputs.name }}"
+        python3 CI/run.py --cache cache --no-recurse --out . "${{ inputs.name }}"

CI/run.py

@@ -29,7 +29,7 @@ def link_or_copy(src, dest):
             raise
 
 
-def run_task(task, cwd, out=None, cache=None):
+def run_task(task, cwd, out=None, cache=None, recurse=True):
     id = task.id
     task = task.task
     payload = task.get("payload", {})
@@ -44,8 +44,12 @@ def run_task(task, cwd, out=None, cache=None):
             else:
                 artifacts_base_dir = os.path.join(cwd, task_id)
             artifact = os.path.join(artifacts_base_dir, content["artifact"])
+            print(artifact, os.path.exists(artifact))
             if not os.path.exists(artifact):
-                run_task(dep_task, cwd, cache=cache)
+                if recurse:
+                    run_task(dep_task, cwd, cache=cache)
+                else:
+                    raise RuntimeError("Missing dependency")
 
             if directory := mount.get("directory"):
                 assert "file" not in mount
@@ -101,6 +105,7 @@ def main():
     parser.add_argument("--out", type=str, metavar="PATH")
     parser.add_argument("--route", action="store_true")
     parser.add_argument("--mounts", action="store_true")
+    parser.add_argument("--no-recurse", action="store_true")
     parser.add_argument("task")
     args = parser.parse_args()
     action.by_name["decision"].func()
@@ -130,7 +135,7 @@ def info(mount):
     with tempfile.TemporaryDirectory(prefix="run_task") as tmpdir:
         for t in Task.by_id.values():
             if t.task.get("metadata", {}).get("name") == args.task:
-                run_task(t, cwd=tmpdir, out=args.out, cache=args.cache)
+                run_task(t, cwd=tmpdir, out=args.out, cache=args.cache, recurse=not args.no_recurse)
                 break