Navigation
index
modules
|
ewoksjob documentation
»
Index
Index
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
J
|
K
|
L
|
M
|
N
|
O
|
P
|
Q
|
R
|
S
|
T
|
U
|
W
A
accept_callback_main() (in module ewoksjob.worker.process)
acquire() (ewoksjob.events.handlers.redis.RedisEwoksEventHandler method)
active (ewoksjob.worker.process.TaskPool property)
(ewoksjob.worker.slurm.TaskPool property)
add_options() (in module ewoksjob.worker.options)
addFilter() (ewoksjob.events.handlers.redis.RedisEwoksEventHandler method)
alias (ewoksjob.worker.options.CustomWorkersBootStep property)
apply_async() (ewoksjob.worker.process.TaskPool method)
(ewoksjob.worker.slurm.TaskPool method)
apply_entry() (ewoksjob.worker.slurm.TaskPool.Timer method)
apply_worker_options() (in module ewoksjob.worker.options)
ApplyResult (class in ewoksjob.worker.process)
args (ewoksjob.worker.process.TaskPool.Timer.Entry attribute)
(ewoksjob.worker.slurm.TaskPool.Timer.Entry attribute)
assert_convert() (in module ewoksjob.tests.test_convert)
assert_submit() (in module ewoksjob.tests.test_convert_and_execute)
(in module ewoksjob.tests.test_execute)
(in module ewoksjob.tests.test_task_discovery)
assert_submit_test() (in module ewoksjob.tests.test_convert_and_execute)
(in module ewoksjob.tests.test_execute)
autodiscover_tasks() (ewoksjob.config.EwoksLoader method)
B
BLOCKING (ewoksjob.events.handlers.redis.RedisEwoksEventHandler attribute)
body_can_be_buffer (ewoksjob.worker.process.TaskPool attribute)
(ewoksjob.worker.slurm.TaskPool attribute)
builtin_modules (ewoksjob.config.EwoksLoader attribute)
C
call_after() (ewoksjob.worker.process.TaskPool.Timer method)
(ewoksjob.worker.slurm.TaskPool.Timer method)
call_at() (ewoksjob.worker.process.TaskPool.Timer method)
(ewoksjob.worker.slurm.TaskPool.Timer method)
call_repeatedly() (ewoksjob.worker.process.TaskPool.Timer method)
(ewoksjob.worker.slurm.TaskPool.Timer method)
cancel() (ewoksjob.worker.process.TaskPool.Timer method)
(ewoksjob.worker.process.TaskPool.Timer.Entry method)
(ewoksjob.worker.slurm.TaskPool.Timer method)
(ewoksjob.worker.slurm.TaskPool.Timer.Entry method)
(in module ewoksjob.client.celery.utils)
(in module ewoksjob.client.local.utils)
canceled (ewoksjob.worker.process.TaskPool.Timer.Entry attribute)
(ewoksjob.worker.slurm.TaskPool.Timer.Entry attribute)
cancelled (ewoksjob.worker.process.TaskPool.Timer.Entry property)
(ewoksjob.worker.slurm.TaskPool.Timer.Entry property)
celery_task_is_bound() (in module ewoksjob.apps.ewoks)
clear() (ewoksjob.worker.process.TaskPool.Timer method)
(ewoksjob.worker.slurm.TaskPool.Timer method)
CLOSE (ewoksjob.worker.process.TaskPool attribute)
(ewoksjob.worker.slurm.TaskPool attribute)
close() (ewoksjob.events.handlers.redis.RedisEwoksEventHandler method)
(ewoksjob.events.readers.base.EwoksEventReader method)
(ewoksjob.events.readers.redis.RedisEwoksEventReader method)
(ewoksjob.events.readers.sqlite3.Sqlite3EwoksEventReader method)
(ewoksjob.worker.process.TaskPool method)
(ewoksjob.worker.slurm.TaskPool method)
cmdline_config_parser() (ewoksjob.config.EwoksLoader method)
conditional (ewoksjob.worker.options.CustomWorkersBootStep attribute)
conf (ewoksjob.config.EwoksLoader property)
config_from_object() (ewoksjob.config.EwoksLoader method)
configured (ewoksjob.config.EwoksLoader attribute)
convert_workflow() (in module ewoksjob.client.celery.tasks)
(in module ewoksjob.client.local.tasks)
create() (ewoksjob.worker.options.CustomWorkersBootStep method)
createLock() (ewoksjob.events.handlers.redis.RedisEwoksEventHandler method)
CustomWorkersBootStep (class in ewoksjob.worker.options)
D
daemon (ewoksjob.worker.process.TaskPool.Timer property)
default_modules (ewoksjob.config.EwoksLoader property)
dereference_data_uris() (ewoksjob.events.readers.base.EwoksEventReader static method)
(ewoksjob.events.readers.redis.RedisEwoksEventReader static method)
(ewoksjob.events.readers.sqlite3.Sqlite3EwoksEventReader static method)
did_start_ok() (ewoksjob.worker.process.TaskPool method)
(ewoksjob.worker.slurm.TaskPool method)
discover_all_tasks() (in module ewoksjob.client.celery.tasks)
(in module ewoksjob.client.local.tasks)
discover_tasks_from_modules() (in module ewoksjob.client.celery.tasks)
(in module ewoksjob.client.local.tasks)
dummy_workflow() (in module ewoksjob.client.dummy_workflow)
E
emit() (ewoksjob.events.handlers.redis.RedisEwoksEventHandler method)
empty() (ewoksjob.worker.process.TaskPool.Timer method)
enabled (ewoksjob.worker.options.CustomWorkersBootStep attribute)
ensure_started() (ewoksjob.worker.process.TaskPool.Timer method)
enter() (ewoksjob.worker.process.TaskPool.Timer method)
enter_after() (ewoksjob.worker.process.TaskPool.Timer method)
(ewoksjob.worker.slurm.TaskPool.Timer method)
enter_at() (ewoksjob.worker.slurm.TaskPool.Timer method)
event_passes_filter() (ewoksjob.events.readers.base.EwoksEventReader static method)
(ewoksjob.events.readers.redis.RedisEwoksEventReader static method)
(ewoksjob.events.readers.sqlite3.Sqlite3EwoksEventReader static method)
EwoksEventReader (class in ewoksjob.events.readers.base)
ewoksjob
module
ewoksjob.apps
module
ewoksjob.apps.ewoks
module
ewoksjob.client
module
ewoksjob.client.celery
module
ewoksjob.client.celery.tasks
module
ewoksjob.client.celery.utils
module
ewoksjob.client.dummy_workflow
module
ewoksjob.client.local
module
ewoksjob.client.local.pool
module
ewoksjob.client.local.tasks
module
ewoksjob.client.local.utils
module
ewoksjob.config
module
ewoksjob.events
module
ewoksjob.events.handlers
module
ewoksjob.events.handlers.redis
module
ewoksjob.events.readers
module
ewoksjob.events.readers.base
module
ewoksjob.events.readers.redis
module
ewoksjob.events.readers.sqlite3
module
ewoksjob.tests
module
ewoksjob.tests.test_convert
module
ewoksjob.tests.test_convert_and_execute
module
ewoksjob.tests.test_execute
module
ewoksjob.tests.test_task_discovery
module
ewoksjob.tests.utils
module
ewoksjob.worker
module
ewoksjob.worker.errors
module
ewoksjob.worker.options
module
ewoksjob.worker.process
module
ewoksjob.worker.process_utils
module
ewoksjob.worker.slurm
module
ewoksjob.worker.task
module
EwoksJobBaseException
EwoksJobBaseExceptionCause
EwoksJobException
EwoksJobExceptionCause
EwoksLoader (class in ewoksjob.config)
execute_graph() (in module ewoksjob.client.celery.tasks)
(in module ewoksjob.client.local.tasks)
execute_test_graph() (in module ewoksjob.client.celery.tasks)
(in module ewoksjob.client.local.tasks)
EXECUTOR_OPTIONS (ewoksjob.worker.process.TaskPool attribute)
(ewoksjob.worker.slurm.TaskPool attribute)
exit_after() (ewoksjob.worker.process.TaskPool.Timer method)
F
FIELD_TYPES (ewoksjob.events.handlers.redis.RedisEwoksEventHandler attribute)
filter() (ewoksjob.events.handlers.redis.RedisEwoksEventHandler method)
find_module() (ewoksjob.config.EwoksLoader method)
flush() (ewoksjob.events.handlers.redis.RedisEwoksEventHandler method)
(ewoksjob.worker.process.TaskPool method)
(ewoksjob.worker.slurm.TaskPool method)
format() (ewoksjob.events.handlers.redis.RedisEwoksEventHandler method)
fun (ewoksjob.worker.process.TaskPool.Timer.Entry attribute)
(ewoksjob.worker.slurm.TaskPool.Timer.Entry attribute)
G
get() (ewoksjob.worker.process.ApplyResult method)
get_active_pool() (in module ewoksjob.client.local.pool)
get_cfg_type() (in module ewoksjob.config)
get_cfg_uri() (in module ewoksjob.config)
get_events() (ewoksjob.events.readers.base.EwoksEventReader method)
(ewoksjob.events.readers.redis.RedisEwoksEventReader method)
(ewoksjob.events.readers.sqlite3.Sqlite3EwoksEventReader method)
get_events_with_variables() (ewoksjob.events.readers.base.EwoksEventReader method)
(ewoksjob.events.readers.redis.RedisEwoksEventReader method)
(ewoksjob.events.readers.sqlite3.Sqlite3EwoksEventReader method)
get_ewoks_task_from_celery_task() (in module ewoksjob.apps.ewoks)
get_executor() (in module ewoksjob.worker.slurm)
get_full_job_events() (ewoksjob.events.readers.base.EwoksEventReader method)
(ewoksjob.events.readers.redis.RedisEwoksEventReader method)
(ewoksjob.events.readers.sqlite3.Sqlite3EwoksEventReader method)
get_full_job_events_with_variables() (ewoksjob.events.readers.base.EwoksEventReader method)
(ewoksjob.events.readers.redis.RedisEwoksEventReader method)
(ewoksjob.events.readers.sqlite3.Sqlite3EwoksEventReader method)
get_future() (in module ewoksjob.client.celery.utils)
(in module ewoksjob.client.local.utils)
get_name() (ewoksjob.events.handlers.redis.RedisEwoksEventHandler method)
get_not_finished_futures() (in module ewoksjob.client.celery.utils)
(in module ewoksjob.client.local.utils)
get_not_finished_task_ids() (in module ewoksjob.client.celery.utils)
(in module ewoksjob.client.local.utils)
get_result() (in module ewoksjob.client.celery.utils)
(in module ewoksjob.client.local.utils)
(in module ewoksjob.tests.utils)
getName() (ewoksjob.worker.process.TaskPool.Timer method)
grow() (ewoksjob.worker.process.TaskPool method)
(ewoksjob.worker.slurm.TaskPool method)
H
handle() (ewoksjob.events.handlers.redis.RedisEwoksEventHandler method)
handle_error() (ewoksjob.worker.slurm.TaskPool.Timer method)
handleError() (ewoksjob.events.handlers.redis.RedisEwoksEventHandler method)
has_redis() (in module ewoksjob.tests.utils)
I
ident (ewoksjob.worker.process.TaskPool.Timer property)
import_default_modules() (ewoksjob.config.EwoksLoader method)
import_from_cwd() (ewoksjob.config.EwoksLoader method)
import_module() (ewoksjob.config.EwoksLoader method)
import_task_module() (ewoksjob.config.EwoksLoader method)
include() (ewoksjob.worker.options.CustomWorkersBootStep method)
include_if() (ewoksjob.worker.options.CustomWorkersBootStep method)
info (ewoksjob.worker.process.TaskPool property)
(ewoksjob.worker.slurm.TaskPool property)
info() (ewoksjob.worker.options.CustomWorkersBootStep method)
init_worker() (ewoksjob.config.EwoksLoader method)
init_worker_process() (ewoksjob.config.EwoksLoader method)
instantiate() (ewoksjob.worker.options.CustomWorkersBootStep method)
instantiate_reader() (in module ewoksjob.events.readers)
is_alive() (ewoksjob.worker.process.TaskPool.Timer method)
is_green (ewoksjob.worker.process.TaskPool attribute)
(ewoksjob.worker.slurm.TaskPool attribute)
isDaemon() (ewoksjob.worker.process.TaskPool.Timer method)
J
join() (ewoksjob.worker.process.TaskPool.Timer method)
K
kwargs (ewoksjob.worker.process.TaskPool.Timer.Entry attribute)
(ewoksjob.worker.slurm.TaskPool.Timer.Entry attribute)
L
label (ewoksjob.worker.options.CustomWorkersBootStep attribute)
last (ewoksjob.worker.options.CustomWorkersBootStep attribute)
M
maintain_pool() (ewoksjob.worker.process.TaskPool method)
(ewoksjob.worker.slurm.TaskPool method)
module
ewoksjob
ewoksjob.apps
ewoksjob.apps.ewoks
ewoksjob.client
ewoksjob.client.celery
ewoksjob.client.celery.tasks
ewoksjob.client.celery.utils
ewoksjob.client.dummy_workflow
ewoksjob.client.local
ewoksjob.client.local.pool
ewoksjob.client.local.tasks
ewoksjob.client.local.utils
ewoksjob.config
ewoksjob.events
ewoksjob.events.handlers
ewoksjob.events.handlers.redis
ewoksjob.events.readers
ewoksjob.events.readers.base
ewoksjob.events.readers.redis
ewoksjob.events.readers.sqlite3
ewoksjob.tests
ewoksjob.tests.test_convert
ewoksjob.tests.test_convert_and_execute
ewoksjob.tests.test_execute
ewoksjob.tests.test_task_discovery
ewoksjob.tests.utils
ewoksjob.worker
ewoksjob.worker.errors
ewoksjob.worker.options
ewoksjob.worker.process
ewoksjob.worker.process_utils
ewoksjob.worker.slurm
ewoksjob.worker.task
N
name (ewoksjob.events.handlers.redis.RedisEwoksEventHandler property)
(ewoksjob.worker.options.CustomWorkersBootStep attribute)
(ewoksjob.worker.process.TaskPool.Timer property)
native_id (ewoksjob.worker.process.TaskPool.Timer property)
next() (ewoksjob.worker.process.TaskPool.Timer method)
now() (ewoksjob.config.EwoksLoader method)
num_processes (ewoksjob.worker.process.TaskPool property)
(ewoksjob.worker.slurm.TaskPool property)
O
on_apply() (ewoksjob.worker.process.TaskPool method)
(ewoksjob.worker.slurm.TaskPool method)
on_close() (ewoksjob.worker.process.TaskPool method)
(ewoksjob.worker.slurm.TaskPool method)
on_error (ewoksjob.worker.slurm.TaskPool.Timer attribute)
on_hard_timeout() (ewoksjob.worker.process.TaskPool method)
(ewoksjob.worker.slurm.TaskPool method)
on_process_cleanup() (ewoksjob.config.EwoksLoader method)
on_soft_timeout() (ewoksjob.worker.process.TaskPool method)
(ewoksjob.worker.slurm.TaskPool method)
on_start() (ewoksjob.worker.process.TaskPool method)
(ewoksjob.worker.slurm.TaskPool method)
on_stop() (ewoksjob.worker.process.TaskPool method)
(ewoksjob.worker.slurm.TaskPool method)
on_task_init() (ewoksjob.config.EwoksLoader method)
on_terminate() (ewoksjob.worker.process.TaskPool method)
(ewoksjob.worker.slurm.TaskPool method)
on_tick (ewoksjob.worker.process.TaskPool.Timer attribute)
on_worker_init() (ewoksjob.config.EwoksLoader method)
on_worker_process_init() (ewoksjob.config.EwoksLoader method)
on_worker_shutdown() (ewoksjob.config.EwoksLoader method)
override_backends (ewoksjob.config.EwoksLoader attribute)
P
parse_exception() (in module ewoksjob.worker.process)
poll_events() (ewoksjob.events.readers.base.EwoksEventReader method)
(ewoksjob.events.readers.redis.RedisEwoksEventReader method)
(ewoksjob.events.readers.sqlite3.Sqlite3EwoksEventReader method)
poll_events_with_variables() (ewoksjob.events.readers.base.EwoksEventReader method)
(ewoksjob.events.readers.redis.RedisEwoksEventReader method)
(ewoksjob.events.readers.sqlite3.Sqlite3EwoksEventReader method)
pool_context() (in module ewoksjob.client.local.pool)
process_initializer() (in module ewoksjob.worker.process)
(in module ewoksjob.worker.process_utils)
Q
queue (ewoksjob.worker.process.TaskPool.Timer property)
(ewoksjob.worker.slurm.TaskPool.Timer property)
R
read_configuration() (ewoksjob.config.EwoksLoader method)
(in module ewoksjob.config)
RedisEwoksEventHandler (class in ewoksjob.events.handlers.redis)
RedisEwoksEventReader (class in ewoksjob.events.readers.redis)
register_with_event_loop() (ewoksjob.worker.process.TaskPool method)
(ewoksjob.worker.slurm.TaskPool method)
release() (ewoksjob.events.handlers.redis.RedisEwoksEventHandler method)
removeFilter() (ewoksjob.events.handlers.redis.RedisEwoksEventHandler method)
replace_exception_for_client() (in module ewoksjob.worker.errors)
requires (ewoksjob.worker.options.CustomWorkersBootStep attribute)
restart() (ewoksjob.worker.process.TaskPool method)
(ewoksjob.worker.slurm.TaskPool method)
result() (in module ewoksjob.client.dummy_workflow)
RUN (ewoksjob.worker.process.TaskPool attribute)
(ewoksjob.worker.slurm.TaskPool attribute)
run() (ewoksjob.worker.process.TaskPool.Timer method)
running (ewoksjob.worker.process.TaskPool.Timer attribute)
S
Schedule (ewoksjob.worker.process.TaskPool.Timer attribute)
schedule (ewoksjob.worker.slurm.TaskPool.Timer property)
set_name() (ewoksjob.events.handlers.redis.RedisEwoksEventHandler method)
setDaemon() (ewoksjob.worker.process.TaskPool.Timer method)
setFormatter() (ewoksjob.events.handlers.redis.RedisEwoksEventHandler method)
setLevel() (ewoksjob.events.handlers.redis.RedisEwoksEventHandler method)
setName() (ewoksjob.worker.process.TaskPool.Timer method)
setup_settings() (ewoksjob.config.EwoksLoader method)
shrink() (ewoksjob.worker.process.TaskPool method)
(ewoksjob.worker.slurm.TaskPool method)
shutdown_worker() (ewoksjob.config.EwoksLoader method)
signal_safe (ewoksjob.worker.process.TaskPool attribute)
(ewoksjob.worker.slurm.TaskPool attribute)
split_filter() (ewoksjob.events.readers.base.EwoksEventReader static method)
(ewoksjob.events.readers.redis.RedisEwoksEventReader static method)
(ewoksjob.events.readers.sqlite3.Sqlite3EwoksEventReader static method)
Sqlite3EwoksEventReader (class in ewoksjob.events.readers.sqlite3)
start() (ewoksjob.worker.process.TaskPool method)
(ewoksjob.worker.process.TaskPool.Timer method)
(ewoksjob.worker.slurm.TaskPool method)
stop() (ewoksjob.worker.process.TaskPool method)
(ewoksjob.worker.process.TaskPool.Timer method)
(ewoksjob.worker.slurm.TaskPool method)
(ewoksjob.worker.slurm.TaskPool.Timer method)
subprocess_main() (in module ewoksjob.worker.process)
T
task_join_will_block (ewoksjob.worker.process.TaskPool attribute)
(ewoksjob.worker.slurm.TaskPool attribute)
TaskPool (class in ewoksjob.worker.process)
(class in ewoksjob.worker.slurm)
TaskPool.Timer (class in ewoksjob.worker.process)
(class in ewoksjob.worker.slurm)
TaskPool.Timer.Entry (class in ewoksjob.worker.process)
(class in ewoksjob.worker.slurm)
TERMINATE (ewoksjob.worker.process.TaskPool attribute)
(ewoksjob.worker.slurm.TaskPool attribute)
terminate() (ewoksjob.worker.process.ApplyResult method)
(ewoksjob.worker.process.TaskPool method)
(ewoksjob.worker.slurm.TaskPool method)
terminate_job() (ewoksjob.worker.process.TaskPool method)
(ewoksjob.worker.slurm.TaskPool method)
test_convert() (in module ewoksjob.tests.test_convert)
test_convert_local() (in module ewoksjob.tests.test_convert)
test_submit() (in module ewoksjob.tests.test_convert_and_execute)
(in module ewoksjob.tests.test_execute)
(in module ewoksjob.tests.test_task_discovery)
test_submit_local() (in module ewoksjob.tests.test_convert_and_execute)
(in module ewoksjob.tests.test_execute)
(in module ewoksjob.tests.test_task_discovery)
tref (ewoksjob.worker.process.TaskPool.Timer.Entry attribute)
(ewoksjob.worker.slurm.TaskPool.Timer.Entry attribute)
U
uses_semaphore (ewoksjob.worker.process.TaskPool attribute)
(ewoksjob.worker.slurm.TaskPool attribute)
W
wait() (ewoksjob.worker.process.ApplyResult method)
wait_events() (ewoksjob.events.readers.base.EwoksEventReader method)
(ewoksjob.events.readers.redis.RedisEwoksEventReader method)
(ewoksjob.events.readers.sqlite3.Sqlite3EwoksEventReader method)
wait_events_with_variables() (ewoksjob.events.readers.base.EwoksEventReader method)
(ewoksjob.events.readers.redis.RedisEwoksEventReader method)
(ewoksjob.events.readers.sqlite3.Sqlite3EwoksEventReader method)
wait_not_finished() (in module ewoksjob.tests.utils)
worker_execute_wrapper() (in module ewoksjob.worker.task)
worker_initialized (ewoksjob.config.EwoksLoader attribute)
Quick search
Navigation
index
modules
|
ewoksjob documentation
»
Index