Skip to content

Commit 395af5e

Browse files
fix: pass cores to remote jobs if they are set
1 parent 245e722 commit 395af5e

1 file changed

Lines changed: 5 additions & 0 deletions

File tree

  • snakemake_interface_executor_plugins/executors

snakemake_interface_executor_plugins/executors/remote.py

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -96,6 +96,11 @@ def __init__(
9696

9797
@property
9898
def cores(self):
99+
cores = self.workflow.resource_settings.cores
100+
# if constrained, pass this info to the job
101+
if cores is not None and cores != sys.maxsize:
102+
return cores
103+
# otherwise, use whatever the node provides
99104
return "all"
100105

101106
def cancel(self):

0 commit comments

Comments
 (0)