fix issue #1028. (#1094)

snakemake/scheduler.py

@@ -641,7 +641,14 @@ def job_selector_ilp(self, jobs):
                 for idx, job in enumerate(jobs)
             }
 
-            size_gb = lambda f: f.size / 1e9
+            def size_gb(f):
+                if self.touch:
+                    # In case of touch mode, there is no need to prioritize based on size.
+                    # We cannot access it anyway, because the files might be temporary and
+                    # not present.
+                    return 0
+                else:
+                    return f.size / 1e9
 
             temp_files = {
                 temp_file for job in jobs for temp_file in self.dag.temp_input(job)

tests/test_touch_pipeline_with_temp_dir/Snakefile

@@ -0,0 +1,16 @@
+rule all:
+    input: "out.txt"
+
+rule input:
+    output: temp("tmp.txt")
+    run:
+        with open(f"{output}", "w") as output:
+            print("tmp", file=output)
+
+rule intemediate:
+    input: "tmp.txt"
+    output: "out.txt"
+    run:
+        with open(f"{input}") as input:
+          with open(f"{output}", "w") as output:
+            print(*input.readlines(), file=output)

tests/test_touch_pipeline_with_temp_dir/expected-results/out.txt

@@ -0,0 +1,2 @@
+tmp
+

tests/test_touch_pipeline_with_temp_dir/out.txt

@@ -0,0 +1,2 @@
+tmp
+

tests/tests.py

@@ -1277,3 +1277,8 @@ def test_github_issue1069():
         dpath("test_github_issue1069"),
         shellcmd="snakemake -c1 --resources mem_mb=16423",
     )
+
+
+def test_touch_pipeline_with_temp_dir():
+    # Issue #1028
+    run(dpath("test_touch_pipeline_with_temp_dir"), forceall=True, touch=True)