ewoksjob.worker.slurm.TaskPool#

class ewoksjob.worker.slurm.TaskPool(*args, **kwargs)[source]#

Bases: TaskPool

SLURM Task Pool.

CLOSE = 2#
EXECUTOR_OPTIONS = {}#
RUN = 1#
TERMINATE = 3#
class Timer(*args, **kwargs)#

Bases: Timer

class Entry(fun, args=None, kwargs=None)#

Bases: object

Schedule Entry.

args#
cancel()#
canceled#
property cancelled#
fun#
kwargs#
tref#
apply_entry(entry)#
call_after(secs, fun, args=(), kwargs=None, priority=0)#
call_at(eta, fun, args=(), kwargs=None, priority=0)#
call_repeatedly(secs, fun, args=(), kwargs=None, priority=0)#
cancel(tref)#
clear()#
enter_after(secs, entry, priority=0, time=<built-in function monotonic>)#
enter_at(entry, eta=None, priority=0, time=<built-in function monotonic>)#

Enter function into the scheduler.

Arguments:#

entry (~kombu.asynchronous.timer.Entry): Item to enter. eta (datetime.datetime): Scheduled time. priority (int): Unused.

handle_error(exc_info)#
on_error = None#
property queue#

Snapshot of underlying datastructure.

property schedule#
stop()#
property active#
apply_async(target, args=None, kwargs=None, **options)#

Equivalent of the apply() built-in function.

Callbacks should optimally return as soon as possible since otherwise the thread which handles the result will get blocked.

body_can_be_buffer = False#
close()#
did_start_ok()#
flush()#
grow(n=1)[source]#
property info#
is_green = True#

set to true if pool uses greenlets.

maintain_pool(*args, **kwargs)#
property num_processes#
on_apply(target, args=None, kwargs=None, callback=None, accept_callback=None, timeout=None, timeout_callback=None, apply_target=<function apply_target>, **_)[source]#
on_close()#
on_hard_timeout(job)#
on_soft_timeout(job)#
on_start()[source]#
on_stop()[source]#
on_terminate()#
register_with_event_loop(loop)#
restart()[source]#
shrink(n=1)[source]#
signal_safe = False#

set to true if the pool can be shutdown from within a signal handler.

start()#
stop()#
task_join_will_block = False#
terminate()#
terminate_job(pid, signal=None)[source]#
uses_semaphore = False#

only used by multiprocessing pool