fix: in addition to localrules statement, infer that job is local if it has any input or output file that is marked as local (#2541)

johanneskoester · web-flow · commit e8b682be0bd5 · 2023-12-11T08:01:32.000+01:00
### QC
&lt;!-- Make sure that you can tick the boxes below. --&gt;

* [x] The PR contains a test case for the changes or the changes are
already covered by an existing test case.
* [x] The documentation (`docs/`) is updated to reflect the changes or
this is not necessary (e.g. if the change does neither modify the
language nor the behavior or functionalities of Snakemake).
diff --git a/snakemake/jobs.py b/snakemake/jobs.py
@@ -906,7 +906,14 @@ def properties(self, omit_resources=["_cores", "_nodes"], **aux_properties):
 
     @property
     def is_local(self):
-        return self.dag.workflow.is_local(self.rule)
+        no_shared_fs = (
+            SharedFSUsage.INPUT_OUTPUT
+            not in self.dag.workflow.storage_settings.shared_fs_usage
+        )
+        return self.dag.workflow.is_local(self.rule) or (
+            no_shared_fs
+            and any(is_flagged(f, "local") for f in chain(self.input, self.output))
+        )
 
     def __repr__(self):
         return self.rule.name
@@ -1406,7 +1413,7 @@ def priority(self):
 
     @property
     def is_local(self):
-        return all(job.is_local for job in self.jobs)
+        return any(job.is_local for job in self.jobs)
 
     def merged_wildcards(self):
         jobs = iter(self.jobs)
