File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change 1
- """Parallel workflow execution via SGE
1
+ """Parallel workflow execution via SLURM
2
2
"""
3
3
4
4
import os
@@ -29,7 +29,7 @@ def node_completed_status( checknode):
29
29
30
30
31
31
class SLURMGraphPlugin (GraphPluginBase ):
32
- """Execute using SGE
32
+ """Execute using SLURM
33
33
34
34
The plugin_args input to run can be used to control the SGE execution.
35
35
Currently supported options are:
@@ -60,14 +60,14 @@ def __init__(self, **kwargs):
60
60
self ._dont_resubmit_completed_jobs = plugin_args ['dont_resubmit_completed_jobs' ]
61
61
else :
62
62
self ._dont_resubmit_completed_jobs = False
63
- super (SGEGraphPlugin , self ).__init__ (** kwargs )
63
+ super (SLURMGraphPlugin , self ).__init__ (** kwargs )
64
64
65
65
def _submit_graph (self , pyfiles , dependencies , nodes ):
66
66
def make_job_name (jobnumber , nodeslist ):
67
67
"""
68
68
- jobnumber: The index number of the job to create
69
69
- nodeslist: The name of the node being processed
70
- - return: A string representing this job to be displayed by SGE
70
+ - return: A string representing this job to be displayed by SLURM
71
71
"""
72
72
job_name = 'j{0}_{1}' .format (jobnumber , nodeslist [jobnumber ]._id )
73
73
# Condition job_name to be a valid bash identifier (i.e. - is invalid)
You can’t perform that action at this time.
0 commit comments