crew_class_launcher_sge {crew.cluster} | R Documentation |
R6
class to launch and manage SGE workers.
See crew_launcher_sge()
.
The template files at
https://github.com/mschubert/clustermq/tree/master/inst
informed the development of the crew
launcher plugins in
crew.cluster
, and we would like to thank
Michael Schubert for developing clustermq
and releasing it under
the permissive Apache License 2.0.
See the NOTICE
and README.md
files in the crew.cluster
source code for additional attribution.
crew::crew_class_launcher
-> crew.cluster::crew_class_launcher_cluster
-> crew_class_launcher_sge
sge_cwd
See crew_launcher_sge()
.
sge_envvars
See crew_launcher_sge()
.
sge_log_output
See crew_launcher_sge()
.
sge_log_error
See crew_launcher_sge()
.
sge_log_join
See crew_launcher_sge()
.
sge_memory_gigabytes_limit
See crew_launcher_sge()
.
sge_memory_gigabytes_required
See crew_launcher_sge()
.
sge_cores
See crew_launcher_sge()
.
sge_gpu
See crew_launcher_sge()
.
crew::crew_class_launcher$active()
crew::crew_class_launcher$booting()
crew::crew_class_launcher$call()
crew::crew_class_launcher$done()
crew::crew_class_launcher$errors()
crew::crew_class_launcher$forward()
crew::crew_class_launcher$launch()
crew::crew_class_launcher$rotate()
crew::crew_class_launcher$scale()
crew::crew_class_launcher$set_name()
crew::crew_class_launcher$settings()
crew::crew_class_launcher$start()
crew::crew_class_launcher$summary()
crew::crew_class_launcher$tally()
crew::crew_class_launcher$terminate()
crew::crew_class_launcher$terminate_workers()
crew::crew_class_launcher$unlaunched()
crew::crew_class_launcher$wait()
crew.cluster::crew_class_launcher_cluster$launch_worker()
crew.cluster::crew_class_launcher_cluster$terminate_worker()
new()
SGE launcher constructor.
crew_class_launcher_sge$new( name = NULL, seconds_interval = NULL, seconds_timeout = NULL, seconds_launch = NULL, seconds_idle = NULL, seconds_wall = NULL, tasks_max = NULL, tasks_timers = NULL, reset_globals = NULL, reset_packages = NULL, reset_options = NULL, garbage_collection = NULL, launch_max = NULL, tls = NULL, verbose = NULL, command_submit = NULL, command_terminate = NULL, script_directory = NULL, script_lines = NULL, sge_cwd = NULL, sge_envvars = NULL, sge_log_output = NULL, sge_log_error = NULL, sge_log_join = NULL, sge_memory_gigabytes_limit = NULL, sge_memory_gigabytes_required = NULL, sge_cores = NULL, sge_gpu = NULL )
name
See crew_launcher_sge()
.
seconds_interval
seconds_timeout
seconds_launch
See crew_launcher_sge()
.
seconds_idle
See crew_launcher_sge()
.
seconds_wall
See crew_launcher_sge()
.
tasks_max
See crew_launcher_sge()
.
tasks_timers
See crew_launcher_sge()
.
reset_globals
See crew_launcher_sge()
.
reset_packages
See crew_launcher_sge()
.
reset_options
See crew_launcher_sge()
.
garbage_collection
See crew_launcher_sge()
.
launch_max
See crew_launcher_sge()
.
tls
See crew_launcher_sge()
.
verbose
See crew_launcher_sge()
.
command_submit
See crew_launcher_sge()
.
command_terminate
See crew_launcher_sge()
.
script_directory
See crew_launcher_sge()
.
script_lines
See crew_launcher_sge()
.
sge_cwd
See crew_launcher_sge()
.
sge_envvars
See crew_launcher_sge()
.
sge_log_output
See crew_launcher_sge()
.
sge_log_error
See crew_launcher_sge()
.
sge_log_join
See crew_launcher_sge()
.
sge_memory_gigabytes_limit
See crew_launcher_sge()
.
sge_memory_gigabytes_required
See crew_launcher_sge()
.
sge_cores
See crew_launcher_sge()
.
sge_gpu
See crew_launcher_sge()
.
an SGE launcher object.
validate()
Validate the launcher.
crew_class_launcher_sge$validate()
NULL
(invisibly). Throws an error if a field is invalid.
script()
Generate the job script.
crew_class_launcher_sge$script(name)
name
Character of length 1, name of the job. For inspection purposes, you can supply a mock job name.
Includes everything except the worker-instance-specific
job name and the worker-instance-specific
call to crew::crew_worker()
, both of which get inserted at
the bottom of the script at launch time.
Character vector of the lines of the job script.
if (identical(Sys.getenv("CREW_EXAMPLES"), "true")) { launcher <- crew_launcher_sge( sge_cores = 2, sge_memory_gigabytes_required = 4 ) launcher$script(name = "my_job_name") }
Other sge:
crew_class_monitor_sge
,
crew_controller_sge()
,
crew_launcher_sge()
,
crew_monitor_sge()
## ------------------------------------------------
## Method `crew_class_launcher_sge$script`
## ------------------------------------------------
if (identical(Sys.getenv("CREW_EXAMPLES"), "true")) {
launcher <- crew_launcher_sge(
sge_cores = 2,
sge_memory_gigabytes_required = 4
)
launcher$script(name = "my_job_name")
}