Index

_

_advance() (radical.entk.appman.wfprocessor.WFprocessor method) (radical.entk.execman.base.task_manager.Base_TaskManager method) _check_stage_complete() (radical.entk.Stage method) _cleanup_mqs() (radical.entk.AppManager method) _create_workload() (radical.entk.appman.wfprocessor.WFprocessor method) _decrement_stage() (radical.entk.Pipeline method) _dequeue() (radical.entk.appman.wfprocessor.WFprocessor method) _enqueue() (radical.entk.appman.wfprocessor.WFprocessor method) _execute_post_exec() (radical.entk.appman.wfprocessor.WFprocessor method) _execute_workload() (radical.entk.appman.wfprocessor.WFprocessor method) _get_message_to_sync() (radical.entk.AppManager method) _heartbeat() (radical.entk.execman.base.task_manager.Base_TaskManager method) _increment_stage() (radical.entk.Pipeline method) _populate() (radical.entk.execman.base.resource_manager.Base_ResourceManager method) (radical.entk.execman.mock.resource_manager.ResourceManager method) _process_tasks() (radical.entk.execman.mock.task_manager.TaskManager method) (radical.entk.execman.rp.task_manager.TaskManager method) _read_config() (radical.entk.AppManager method) _run_workflow() (radical.entk.AppManager method) _set_tasks_state() (radical.entk.Stage method) _setup_mqs() (radical.entk.AppManager method)

_start_all_comps() (radical.entk.AppManager method) _submit_resource_request() (radical.entk.execman.base.resource_manager.Base_ResourceManager method) (radical.entk.execman.mock.resource_manager.ResourceManager method) (radical.entk.execman.rp.resource_manager.ResourceManager method) _sync_with_master() (radical.entk.execman.base.task_manager.Base_TaskManager method) _synchronizer() (radical.entk.AppManager method) _synchronizer_work() (radical.entk.AppManager method) _terminate_resource_request() (radical.entk.execman.base.resource_manager.Base_ResourceManager method) (radical.entk.execman.mock.resource_manager.ResourceManager method) (radical.entk.execman.rp.resource_manager.ResourceManager method) _tmgr() (radical.entk.execman.base.task_manager.Base_TaskManager method) (radical.entk.execman.mock.task_manager.TaskManager method) (radical.entk.execman.rp.task_manager.TaskManager method) _update_dequeued_task() (radical.entk.appman.wfprocessor.WFprocessor method) _update_task() (radical.entk.AppManager method) _validate() (radical.entk.Pipeline method) (radical.entk.Stage method) (radical.entk.Task method) _validate_entities() (radical.entk.Pipeline class method) (radical.entk.Stage class method) _validate_resource_desc() (radical.entk.execman.base.resource_manager.Base_ResourceManager method) (radical.entk.execman.mock.resource_manager.ResourceManager method)

A

access_schema (radical.entk.execman.base.resource_manager.Base_ResourceManager attribute) add_stages() (radical.entk.Pipeline method)

add_tasks() (radical.entk.Stage method) AppManager (class in radical.entk) arguments (radical.entk.Task attribute)

B

Base_ResourceManager (class in radical.entk.execman.base.resource_manager)

Base_TaskManager (class in radical.entk.execman.base.task_manager)

C

check_heartbeat() (radical.entk.execman.base.task_manager.Base_TaskManager method) check_manager() (radical.entk.execman.base.task_manager.Base_TaskManager method) check_processor() (radical.entk.appman.wfprocessor.WFprocessor method) completed (radical.entk.Pipeline attribute)

copy_input_data (radical.entk.Task attribute) copy_output_data (radical.entk.Task attribute) cpu_reqs (radical.entk.Task attribute) cpus (radical.entk.execman.base.resource_manager.Base_ResourceManager attribute) current_stage (radical.entk.Pipeline attribute)

D

download_output_data (radical.entk.Task attribute)

E

EnTKError

executable (radical.entk.Task attribute) exit_code (radical.entk.Task attribute)

F

from_dict() (radical.entk.Pipeline method) (radical.entk.Stage method) (radical.entk.Task method)

G

get_completed_states() (radical.entk.execman.base.resource_manager.Base_ResourceManager method) (radical.entk.execman.mock.resource_manager.ResourceManager method) (radical.entk.execman.rp.resource_manager.ResourceManager method) get_resource_allocation_state() (radical.entk.execman.base.resource_manager.Base_ResourceManager method) (radical.entk.execman.mock.resource_manager.ResourceManager method) (radical.entk.execman.rp.resource_manager.ResourceManager method)

gpu_reqs (radical.entk.Task attribute) gpus (radical.entk.execman.base.resource_manager.Base_ResourceManager attribute)

J

job_name (radical.entk.execman.base.resource_manager.Base_ResourceManager attribute)

L

lfs_per_process (radical.entk.Task attribute) link_input_data (radical.entk.Task attribute) link_output_data (radical.entk.Task attribute)

lock (radical.entk.Pipeline attribute) luid (radical.entk.Pipeline attribute) (radical.entk.Stage attribute) (radical.entk.Task attribute)

M

MissingError

move_input_data (radical.entk.Task attribute) move_output_data (radical.entk.Task attribute)

N

name (radical.entk.AppManager attribute) (radical.entk.Pipeline attribute) (radical.entk.Stage attribute) (radical.entk.Task attribute)

O

outputs (radical.entk.AppManager attribute) (radical.entk.execman.base.resource_manager.Base_ResourceManager attribute)

P

parent_pipeline (radical.entk.Stage attribute) (radical.entk.Task attribute) parent_stage (radical.entk.Task attribute) path (radical.entk.Task attribute) pilot (radical.entk.execman.rp.resource_manager.ResourceManager attribute)

Pipeline (class in radical.entk) pmgr (radical.entk.execman.rp.resource_manager.ResourceManager attribute) post_exec (radical.entk.Stage attribute) (radical.entk.Task attribute) pre_exec (radical.entk.Task attribute) project (radical.entk.execman.base.resource_manager.Base_ResourceManager attribute)

Q

queue (radical.entk.execman.base.resource_manager.Base_ResourceManager attribute)

R

radical.entk.exceptions (module) resource (radical.entk.execman.base.resource_manager.Base_ResourceManager attribute) resource_desc (radical.entk.AppManager attribute) resource_terminate() (radical.entk.AppManager method)

ResourceManager (class in radical.entk.execman.mock.resource_manager) (class in radical.entk.execman.rp.resource_manager) resume() (radical.entk.Pipeline method) rts_uid (radical.entk.Task attribute) run() (radical.entk.AppManager method)

S

sandbox (radical.entk.Task attribute) session (radical.entk.execman.rp.resource_manager.ResourceManager attribute) shared_data (radical.entk.AppManager attribute) (radical.entk.execman.base.resource_manager.Base_ResourceManager attribute) sid (radical.entk.AppManager attribute) Stage (class in radical.entk) stages (radical.entk.Pipeline attribute) start_heartbeat() (radical.entk.execman.base.task_manager.Base_TaskManager method) start_manager() (radical.entk.execman.base.task_manager.Base_TaskManager method) (radical.entk.execman.mock.task_manager.TaskManager method) (radical.entk.execman.rp.task_manager.TaskManager method)

start_processor() (radical.entk.appman.wfprocessor.WFprocessor method) state (radical.entk.Pipeline attribute) (radical.entk.Stage attribute) (radical.entk.Task attribute) state_history (radical.entk.Pipeline attribute) (radical.entk.Stage attribute) (radical.entk.Task attribute) stderr (radical.entk.Task attribute) stdout (radical.entk.Task attribute) suspend() (radical.entk.Pipeline method)

T

tag (radical.entk.Task attribute) Task (class in radical.entk) TaskManager (class in radical.entk.execman.mock.task_manager) (class in radical.entk.execman.rp.task_manager) tasks (radical.entk.Stage attribute) terminate() (radical.entk.AppManager method)

terminate_heartbeat() (radical.entk.execman.base.task_manager.Base_TaskManager method) terminate_manager() (radical.entk.execman.base.task_manager.Base_TaskManager method) terminate_processor() (radical.entk.appman.wfprocessor.WFprocessor method) to_dict() (radical.entk.Pipeline method) (radical.entk.Stage method) (radical.entk.Task method) TypeError

U

uid (radical.entk.Pipeline attribute) (radical.entk.Stage attribute) (radical.entk.Task attribute)

upload_input_data (radical.entk.Task attribute)

V

ValueError

W

walltime (radical.entk.execman.base.resource_manager.Base_ResourceManager attribute) WFprocessor (class in radical.entk.appman.wfprocessor) workflow (radical.entk.appman.wfprocessor.WFprocessor attribute) (radical.entk.AppManager attribute)

workflow_incomplete() (radical.entk.appman.wfprocessor.WFprocessor method) workflows (radical.entk.AppManager attribute)