Index

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_tasks_from_modules() (in module ewoksjob.client.celery.tasks) (in module ewoksjob.client.local.tasks)

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.local module ewoksjob.client.local.pool module ewoksjob.client.local.tasks module ewoksjob.client.local.utils module ewoksjob.client.test_workflow 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_server() (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.local ewoksjob.client.local.pool ewoksjob.client.local.tasks ewoksjob.client.local.utils ewoksjob.client.test_workflow 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.test_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) test_workflow() (in module ewoksjob.client.test_workflow) 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)