@@ -191,15 +191,6 @@ def check_for_abstract_op(tool: CWLObjectType) -> None:
191
191
return (self .final_output [0 ], self .final_status [0 ])
192
192
return (None , "permanentFail" )
193
193
194
- def message_about_other_runners (self ) -> None :
195
- _logger .info (
196
- "Need to grow beyond `cwltool` and scale up your workflows to run on a multi-node cluster, or in the cloud?"
197
- )
198
- _logger .info (
199
- "CWL workflows are portable and run on many commercial and open source platforms."
200
- )
201
- _logger .info ("Visit https://www.commonwl.org/implementations/ to learn more." )
202
-
203
194
204
195
class SingleJobExecutor (JobExecutor ):
205
196
"""Default single-threaded CWL reference executor."""
@@ -212,10 +203,6 @@ def run_jobs(
212
203
runtime_context : RuntimeContext ,
213
204
) -> None :
214
205
215
- _logger .info (
216
- "Using default serial job executor. Use `cwltool --parallel` to run multiple steps at a time."
217
- )
218
-
219
206
process_run_id = None # type: Optional[str]
220
207
221
208
# define provenance profile for single commandline tool
@@ -265,7 +252,6 @@ def run_jobs(
265
252
else :
266
253
logger .error ("Workflow cannot make any more progress." )
267
254
break
268
- self .message_about_other_runners ()
269
255
except (
270
256
ValidationException ,
271
257
WorkflowException ,
@@ -430,10 +416,6 @@ def run_jobs(
430
416
runtime_context : RuntimeContext ,
431
417
) -> None :
432
418
433
- _logger .info (
434
- "Using parallel job executor. Multiple steps will run at once as hardware resources permit."
435
- )
436
-
437
419
self .taskqueue = TaskQueue (
438
420
threading .Lock (), psutil .cpu_count ()
439
421
) # type: TaskQueue
@@ -474,7 +456,6 @@ def run_jobs(
474
456
finally :
475
457
self .taskqueue .drain ()
476
458
self .taskqueue .join ()
477
- self .message_about_other_runners ()
478
459
479
460
480
461
class NoopJobExecutor (JobExecutor ):
0 commit comments