@@ -51,7 +51,6 @@ def run_jobs(self,
51
51
runtime_context # type: RuntimeContext
52
52
): # type: (...) -> None
53
53
""" Execute the jobs for the given Process. """
54
- pass
55
54
56
55
def execute (self ,
57
56
process , # type: Process
@@ -81,26 +80,20 @@ def execute(self,
81
80
if process .metadata ["cwlVersion" ] == 'v1.0' :
82
81
raise WorkflowException (
83
82
"`cwl:requirements` in the input object is not part of CWL "
84
- "v1.0. You can use `cwltool:requirements ` instead; or you "
83
+ "v1.0. You can adjust to use `cwltool:overrides ` instead; or you "
85
84
"can set the cwlVersion to v1.1.0-dev1 or greater and re-run with "
86
85
"--enable-dev." )
87
86
job_reqs = job_order_object ["https://w3id.org/cwl/cwl#requirements" ]
88
- elif "http://commonwl.org/cwltool#requirements" in job_order_object :
89
- job_reqs = job_order_object ["http://commonwl.org/cwltool#requirements" ]
90
87
elif ("cwl:defaults" in process .metadata
91
88
and "https://w3id.org/cwl/cwl#requirements"
92
89
in process .metadata ["cwl:defaults" ]):
93
90
if process .metadata ["cwlVersion" ] == 'v1.0' :
94
91
raise WorkflowException (
95
92
"`cwl:requirements` in the input object is not part of CWL "
96
- "v1.0. You can use `cwltool:requirements ` instead; or you "
93
+ "v1.0. You can adjust to use `cwltool:overrides ` instead; or you "
97
94
"can set the cwlVersion to v1.1.0-dev1 or greater and re-run with "
98
95
"--enable-dev." )
99
96
job_reqs = process .metadata ["cwl:defaults" ]["https://w3id.org/cwl/cwl#requirements" ]
100
- elif ("cwl:defaults" in process .metadata
101
- and "http://commonwl.org/cwltool#requirements"
102
- in process .metadata ["cwl:defaults" ]):
103
- job_reqs = process .metadata ["cwl:defaults" ]["http://commonwl.org/cwltool#requirements" ]
104
97
if job_reqs is not None :
105
98
for req in job_reqs :
106
99
process .requirements .append (req )
@@ -251,10 +244,11 @@ def run_job(self,
251
244
while self .pending_jobs :
252
245
with self .pending_jobs_lock :
253
246
job = self .pending_jobs [0 ]
254
- if isinstance (job , JobBase ) and \
247
+ if isinstance (job , JobBase ) \
248
+ and \
255
249
((self .allocated_ram + job .builder .resources ["ram" ])
256
- > self .max_ram or
257
- (self .allocated_cores + job .builder .resources ["cores" ])
250
+ > self .max_ram
251
+ or (self .allocated_cores + job .builder .resources ["cores" ])
258
252
> self .max_cores ):
259
253
_logger .warning (
260
254
'Job "%s" requested more resources (%s) than are '
0 commit comments