Index

_

_advance() (radical.entk.appman.wfprocessor.WFprocessor method) (radical.entk.execman.base.task_manager.Base_TaskManager method) _cast (radical.entk.Task attribute) _check (radical.entk.Task attribute) _check_stage_complete() (radical.entk.Stage method) _create_workload() (radical.entk.appman.wfprocessor.WFprocessor method) _decrement_stage() (radical.entk.Pipeline method) _defaults (radical.entk.Task attribute) _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) _increment_stage() (radical.entk.Pipeline method) _populate() (radical.entk.execman.base.resource_manager.Base_ResourceManager method) (radical.entk.execman.mock.resource_manager.ResourceManager method) _post_verifier() (radical.entk.Task 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) _schema (radical.entk.Task attribute) _self_default (radical.entk.Task attribute) _set_tasks_state() (radical.entk.Stage method) _setup_zmq() (radical.entk.appman.wfprocessor.WFprocessor method) (radical.entk.AppManager method) (radical.entk.execman.base.task_manager.Base_TaskManager method)

_start_all_comps() (radical.entk.AppManager method) _submit_rts_tmgr() (radical.entk.AppManager 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) _uids (radical.entk.Task attribute) _update_dequeued_task() (radical.entk.appman.wfprocessor.WFprocessor method) _update_resource() (radical.entk.execman.rp.task_manager.TaskManager 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) _verify() (radical.entk.Task method) _verify_setter() (radical.entk.Task method)

A

access_schema (radical.entk.execman.base.resource_manager.Base_ResourceManager property) add_stages() (radical.entk.Pipeline method) add_tasks() (radical.entk.Stage method)

AppManager (class in radical.entk) as_dict() (radical.entk.Pipeline method) (radical.entk.Stage method)

B

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

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

C

check_manager() (radical.entk.execman.base.task_manager.Base_TaskManager method) check_processor() (radical.entk.appman.wfprocessor.WFprocessor method)

completed (radical.entk.Pipeline property) cpus (radical.entk.execman.base.resource_manager.Base_ResourceManager property) current_stage (radical.entk.Pipeline property)

E

EnTKError EnTKMissingError

EnTKTypeError EnTKValueError

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)

get_rts_info() (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) gpus (radical.entk.execman.base.resource_manager.Base_ResourceManager property)

J

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

L

lock (radical.entk.Pipeline property) luid (radical.entk.Pipeline property) (radical.entk.Stage property) (radical.entk.Task property), [1], [2]

M

memory (radical.entk.execman.base.resource_manager.Base_ResourceManager property)

module radical.entk.exceptions

N

name (radical.entk.AppManager property) (radical.entk.Pipeline property) (radical.entk.Stage property)

O

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

P

parent_pipeline (radical.entk.Stage property) pilot (radical.entk.execman.rp.resource_manager.ResourceManager property) Pipeline (class in radical.entk)

pmgr (radical.entk.execman.rp.resource_manager.ResourceManager property) post_exec (radical.entk.Stage property) project (radical.entk.execman.base.resource_manager.Base_ResourceManager property)

Q

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

R

radical.entk.exceptions module reset_workflow() (radical.entk.appman.wfprocessor.WFprocessor method) resource (radical.entk.execman.base.resource_manager.Base_ResourceManager property) resource_desc (radical.entk.AppManager property)

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) run() (radical.entk.AppManager method)

S

session (radical.entk.execman.rp.resource_manager.ResourceManager property) shared_data (radical.entk.AppManager property) (radical.entk.execman.base.resource_manager.Base_ResourceManager property) sid (radical.entk.AppManager property) Stage (class in radical.entk) stages (radical.entk.Pipeline property) 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 property) (radical.entk.Stage property) state_history (radical.entk.Pipeline property) (radical.entk.Stage property) 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) suspend() (radical.entk.Pipeline method)

T

Task (class in radical.entk) Task.arguments (in module radical.entk), [1] Task.copy_input_data (in module radical.entk), [1] Task.copy_output_data (in module radical.entk), [1] Task.cpu_reqs (in module radical.entk), [1] Task.download_output_data (in module radical.entk), [1] Task.environment (in module radical.entk), [1] Task.exception (in module radical.entk), [1] Task.exception_detail (in module radical.entk), [1] Task.executable (in module radical.entk), [1] Task.exit_code (in module radical.entk), [1] Task.gpu_reqs (in module radical.entk), [1] Task.lfs_per_process (in module radical.entk), [1] Task.link_input_data (in module radical.entk), [1] Task.link_output_data (in module radical.entk), [1] Task.mem_per_process (in module radical.entk), [1] Task.move_input_data (in module radical.entk), [1] Task.move_output_data (in module radical.entk), [1] Task.name (in module radical.entk), [1] Task.parent_pipeline (in module radical.entk), [1] Task.parent_stage (in module radical.entk), [1]

Task.path (in module radical.entk), [1] Task.post_exec (in module radical.entk), [1] Task.post_launch (in module radical.entk), [1] Task.pre_exec (in module radical.entk), [1] Task.pre_launch (in module radical.entk), [1] Task.rts_uid (in module radical.entk), [1] Task.sandbox (in module radical.entk), [1] Task.stage_on_error (in module radical.entk), [1] Task.state (in module radical.entk), [1] Task.state_history (in module radical.entk), [1] Task.stderr (in module radical.entk), [1] Task.stdout (in module radical.entk), [1] Task.tags (in module radical.entk), [1] Task.uid (in module radical.entk), [1] Task.upload_input_data (in module radical.entk), [1] TaskManager (class in radical.entk.execman.mock.task_manager) (class in radical.entk.execman.rp.task_manager) tasks (radical.entk.Stage property) terminate() (radical.entk.AppManager method) terminate_manager() (radical.entk.execman.base.task_manager.Base_TaskManager method) terminate_processor() (radical.entk.appman.wfprocessor.WFprocessor method)

U

uid (radical.entk.Pipeline property) (radical.entk.Stage property)

W

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

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