ewoksjob.worker.slurm.TaskPool

class ewoksjob.worker.slurm.TaskPool(*args, **kwargs)

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)

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>, **_)

on_close()

on_hard_timeout(job)

on_soft_timeout(job)

on_start()

on_stop()

on_terminate()

register_with_event_loop(loop)

restart()

shrink(n=1)

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)

uses_semaphore = False

only used by multiprocessing pool