fix: remove erroneous assert in the scheduler (is_main_process) (#3881)

johanneskoester · web-flow · commit d5acdd121955 · 2025-12-15T14:49:59.000+01:00
&lt;!--Add a description of your PR here--&gt;

### 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).


&lt;!-- This is an auto-generated comment: release notes by coderabbit.ai
--&gt;

## Summary by CodeRabbit

* **Bug Fixes**
* Enhanced job scheduling for remote execution environments with
improved handling of shared filesystem configurations and more flexible
storage input retrieval logic across different execution scenarios.

&lt;sub&gt;✏️ Tip: You can customize this high-level summary in your review
settings.&lt;/sub&gt;

&lt;!-- end of auto-generated comment: release notes by coderabbit.ai --&gt;
diff --git a/src/snakemake/scheduling/job_scheduler.py b/src/snakemake/scheduling/job_scheduler.py
@@ -359,13 +359,15 @@ def schedule(self):
                                 executor=self._local_executor or self._executor,
                             )
                     if runjobs:
-                        # If we are already in a remote process, there are for now only local jobs.
+                        is_shared_fs = (
+                            SharedFSUsage.STORAGE_LOCAL_COPIES
+                            in self.workflow.storage_settings.shared_fs_usage
+                        )
                         # TODO: there are plans to chain remote executors. In that case, we should
                         # reconsider this logic and decide where to download the storage inputs.
-                        assert self.workflow.is_main_process
                         if not self.workflow.dryrun and (
-                            SharedFSUsage.STORAGE_LOCAL_COPIES
-                            in self.workflow.storage_settings.shared_fs_usage
+                            (self.workflow.is_main_process and is_shared_fs)
+                            or (not is_shared_fs and self.workflow.remote_exec)
                         ):
                             # Retrieve storage inputs for remote jobs, as storage local copies are handled
                             # via a shared filesystem.
