Index

_

__init__() (radical.pilot.PilotManager method) (radical.pilot.Session method) (radical.pilot.TaskManager method)

_configure() (radical.pilot.agent.scheduler.continuous.Continuous method) _find_resources() (radical.pilot.agent.scheduler.continuous.Continuous method) _iterate_nodes() (radical.pilot.agent.scheduler.continuous.Continuous method)

A

access_schema (radical.pilot.PilotDescription attribute) add_pilots() (radical.pilot.TaskManager method) advance() (radical.pilot.utils.component.AgentComponent method) (radical.pilot.utils.component.BaseComponent method) (radical.pilot.utils.component.ClientComponent method) AgentComponent (class in radical.pilot.utils.component) AgentSchedulingComponent (class in radical.pilot.agent.scheduler.base) alive() (radical.pilot.raptor.Master method)

app_comm (radical.pilot.PilotDescription attribute) args (radical.pilot.TaskDescription attribute) arguments (radical.pilot.TaskDescription attribute) as_dict() (radical.pilot.Pilot method) (radical.pilot.PilotManager method) (radical.pilot.Session method) (radical.pilot.Task method) (radical.pilot.TaskManager method)

B

BaseComponent (class in radical.pilot.utils.component)

C

cancel() (radical.pilot.Pilot method) (radical.pilot.Task method) cancel_pilots() (radical.pilot.PilotManager method) cancel_tasks() (radical.pilot.TaskManager method) cleanup (radical.pilot.PilotDescription attribute) (radical.pilot.TaskDescription attribute) client_sandbox (radical.pilot.Task property) ClientComponent (class in radical.pilot.utils.component) close() (radical.pilot.PilotManager method) (radical.pilot.Session method) (radical.pilot.TaskManager method)

code (radical.pilot.TaskDescription attribute) command (radical.pilot.TaskDescription attribute) Continuous (class in radical.pilot.agent.scheduler.continuous) control_cb() (radical.pilot.agent.scheduler.base.AgentSchedulingComponent method) (radical.pilot.PilotManager method) (radical.pilot.raptor.Master method) (radical.pilot.utils.component.BaseComponent method) cores (radical.pilot.PilotDescription attribute) cores_per_rank (radical.pilot.TaskDescription attribute) create_tar() (in module radical.pilot.utils.misc)

D

description (radical.pilot.Pilot property) (radical.pilot.Task property)

deserialize_file() (in module radical.pilot.utils.serializer) deserialize_obj() (in module radical.pilot.utils.serializer)

E

enable_ep (radical.pilot.PilotDescription attribute) endpoint_fs (radical.pilot.Pilot property) (radical.pilot.Task property) environment (radical.pilot.TaskDescription attribute) environment variable <NS>_LOG_LVL <NS>_LOG_TGT, [1] <NS>_REPORT \*_PROFILE RADICAL_BASE RADICAL_DEBUG, [1], [2], [3] RADICAL_DEBUG_HELPER RADICAL_DEBUG_VERBOSE RADICAL_DEFAULT_LOG_DIR RADICAL_DEFAULT_LOG_LVL RADICAL_DEFAULT_LOG_TGT RADICAL_DEFAULT_PROFILE RADICAL_DEFAULT_PROFILE_DIR RADICAL_DEFAULT_REPORT RADICAL_DEFAULT_REPORT_DIR RADICAL_DEFAULT_REPORT_TGT RADICAL_PILOT_BULK_CB RADICAL_PILOT_PROXY_URL RADICAL_PILOT_PRUN_VERBOSE RADICAL_PILOT_SID_BASE RADICAL_SAGA_PTY_CONN_POOL_SIZE RADICAL_SAGA_PTY_CONN_POOL_TTL RADICAL_SAGA_PTY_CONN_POOL_WAIT RADICAL_SAGA_PTY_SSH_COPYMODE RADICAL_SAGA_PTY_SSH_PROMPT RADICAL_SAGA_PTY_SSH_SHAREMODE RADICAL_SAGA_PTY_SSH_TIMEOUT RADICAL_SAGA_SMT RADICAL_UTILS_NO_ATFORK RADICAL_UTILS_NTPHOST RP_ENABLE_OLD_DEFINES RP_PROF_DEBUG RU_RAISE_ON_\* UMS_OMPIX_PRRTE_DIR

exception (radical.pilot.Task property) exception_detail (radical.pilot.Task property) executable (radical.pilot.TaskDescription attribute) exit_code (radical.pilot.Task property) exit_on_error (radical.pilot.PilotDescription attribute)

F

FastTypedDict (class in radical.pilot.utils.misc)

fetch_filetype() (in module radical.pilot.utils.session) function (radical.pilot.TaskDescription attribute)

G

get_consumed_resources() (in module radical.pilot.utils.prof_utils) get_dispatcher() (radical.pilot.raptor.Worker method) get_hostmap() (in module radical.pilot.utils.prof_utils) get_hostmap_deprecated() (in module radical.pilot.utils.prof_utils) get_input_ep() (radical.pilot.utils.component.BaseComponent method) get_master() (radical.pilot.raptor.Worker method) get_output_ep() (radical.pilot.utils.component.BaseComponent method) get_pilot_managers() (radical.pilot.Session method) get_pilots() (radical.pilot.PilotManager method) (radical.pilot.TaskManager method) get_provided_resources() (in module radical.pilot.utils.prof_utils)

get_resource_config() (in module radical.pilot.utils.misc) (radical.pilot.Session method) get_resource_configs() (in module radical.pilot.utils.misc) get_resource_fs_url() (in module radical.pilot.utils.misc) get_resource_job_url() (in module radical.pilot.utils.misc) get_resource_timelines() (in module radical.pilot.utils.prof_utils) get_session_description() (in module radical.pilot.utils.prof_utils) get_task_managers() (radical.pilot.Session method) get_tasks() (radical.pilot.TaskManager method) gpu_type (radical.pilot.TaskDescription attribute) gpus (radical.pilot.PilotDescription attribute) gpus_per_rank (radical.pilot.TaskDescription attribute)

I

info (radical.pilot.Task property) info_pattern (radical.pilot.TaskDescription attribute) inject_metadata() (radical.pilot.Session method)

input_staging (radical.pilot.PilotDescription attribute) (radical.pilot.TaskDescription attribute) is_canceled() (radical.pilot.utils.component.BaseComponent method)

J

job_name (radical.pilot.PilotDescription attribute)

join() (radical.pilot.raptor.Master method) (radical.pilot.raptor.Worker method)

K

kill_pilots() (radical.pilot.PilotManager method)

kwargs (radical.pilot.TaskDescription attribute)

L

lfs_per_rank (radical.pilot.TaskDescription attribute) list_pilot_managers() (radical.pilot.Session method) list_pilots() (radical.pilot.PilotManager method) (radical.pilot.TaskManager method)

list_resources() (radical.pilot.Session method) list_task_managers() (radical.pilot.Session method) list_tasks() (radical.pilot.TaskManager method) log (radical.pilot.Pilot property)

M

Master (class in radical.pilot.raptor) mem_per_rank (radical.pilot.TaskDescription attribute) memory (radical.pilot.PilotDescription attribute) metadata (radical.pilot.Task property) (radical.pilot.TaskDescription attribute) mode (radical.pilot.Task property) (radical.pilot.TaskDescription attribute)

module radical.pilot radical.pilot.utils.component radical.pilot.utils.misc radical.pilot.utils.prof_utils radical.pilot.utils.serializer radical.pilot.utils.session

N

name (radical.pilot.Task property) (radical.pilot.TaskDescription attribute)

named_env (radical.pilot.TaskDescription attribute) nodelist (radical.pilot.Pilot property) nodes (radical.pilot.PilotDescription attribute)

O

origin (radical.pilot.Task property) output() (radical.pilot.utils.component.BaseComponent method)

output_files (radical.pilot.Task property) output_staging (radical.pilot.PilotDescription attribute) (radical.pilot.TaskDescription attribute)

P

partition (radical.pilot.Task property) (radical.pilot.TaskDescription attribute) Pilot (class in radical.pilot) pilot (radical.pilot.Task property) (radical.pilot.TaskDescription attribute) pilot_rpc() (radical.pilot.TaskManager method) pilot_sandbox (radical.pilot.Pilot property) (radical.pilot.Task property) PilotDescription (class in radical.pilot) PilotManager (class in radical.pilot)

pmgr (radical.pilot.Pilot property) post_exec (radical.pilot.TaskDescription attribute) post_launch (radical.pilot.TaskDescription attribute) pre_exec (radical.pilot.TaskDescription attribute) pre_exec_sync (radical.pilot.TaskDescription attribute) pre_launch (radical.pilot.TaskDescription attribute) prepare_env (radical.pilot.PilotDescription attribute) prepare_env() (radical.pilot.Pilot method) priority (radical.pilot.TaskDescription attribute) project (radical.pilot.PilotDescription attribute) publish() (radical.pilot.utils.component.BaseComponent method)

Q

queue (radical.pilot.PilotDescription attribute)

R

radical.pilot module radical.pilot.utils.component module radical.pilot.utils.misc module radical.pilot.utils.prof_utils module radical.pilot.utils.serializer module radical.pilot.utils.session module RADICAL_DEBUG, [1], [2] ranks (radical.pilot.TaskDescription attribute) ranks_per_node (radical.pilot.TaskDescription attribute) Raptor (class in radical.pilot.raptor_tasks) raptor_class (radical.pilot.TaskDescription attribute) raptor_file (radical.pilot.TaskDescription attribute) raptor_id (radical.pilot.TaskDescription attribute) reconfig_src (radical.pilot.PilotDescription attribute) register_callback() (radical.pilot.Pilot method) (radical.pilot.PilotManager method) (radical.pilot.Task method) (radical.pilot.TaskManager method)

register_input() (radical.pilot.utils.component.BaseComponent method) register_mode() (radical.pilot.raptor.Worker method) register_output() (radical.pilot.utils.component.BaseComponent method) register_publisher() (radical.pilot.utils.component.BaseComponent method) register_service() (radical.pilot.Pilot method) register_subscriber() (radical.pilot.utils.component.BaseComponent method) register_timed_cb() (radical.pilot.utils.component.BaseComponent method) remove_pilots() (radical.pilot.TaskManager method) request_cb() (radical.pilot.raptor.Master method) resource (radical.pilot.Pilot property) (radical.pilot.PilotDescription attribute) resource_details (radical.pilot.Pilot property) resource_sandbox (radical.pilot.Pilot property) (radical.pilot.Task property) resources (radical.pilot.Pilot property) rest_url() (radical.pilot.Pilot method) restartable (radical.pilot.TaskDescription attribute) result_cb() (radical.pilot.raptor.Master method) return_value (radical.pilot.Task property) rpc() (radical.pilot.Pilot method) (radical.pilot.raptor_tasks.Raptor method) (radical.pilot.utils.component.BaseComponent method) runtime (radical.pilot.PilotDescription attribute)

S

sandbox (radical.pilot.PilotDescription attribute) (radical.pilot.Task property) (radical.pilot.TaskDescription attribute) schedule_task() (radical.pilot.agent.scheduler.continuous.Continuous method) scheduler (radical.pilot.TaskDescription attribute) (radical.pilot.TaskManager property) serialize_file() (in module radical.pilot.utils.serializer) serialize_obj() (in module radical.pilot.utils.serializer) services (radical.pilot.PilotDescription attribute) (radical.pilot.TaskDescription attribute) Session (class in radical.pilot) session (radical.pilot.Pilot property) (radical.pilot.Task property) session_sandbox (radical.pilot.Pilot property) (radical.pilot.Task property) slot_status() (radical.pilot.agent.scheduler.base.AgentSchedulingComponent method) slots (radical.pilot.Task property) (radical.pilot.TaskDescription attribute) stage_in() (radical.pilot.Pilot method) stage_on_error (radical.pilot.TaskDescription attribute) stage_out() (radical.pilot.Pilot method)

start() (radical.pilot.raptor.Master method) (radical.pilot.raptor.Worker method) startup_timeout (radical.pilot.TaskDescription attribute) state (radical.pilot.Pilot property) (radical.pilot.Task property) stderr (radical.pilot.Pilot property) (radical.pilot.Task property) (radical.pilot.TaskDescription attribute) stdout (radical.pilot.Pilot property) (radical.pilot.Task property) (radical.pilot.TaskDescription attribute) stop() (radical.pilot.raptor.Master method) (radical.pilot.raptor.Worker method) (radical.pilot.utils.component.BaseComponent method) submit_pilots() (radical.pilot.PilotManager method) submit_raptors() (radical.pilot.TaskManager method) submit_tasks() (radical.pilot.raptor.Master method) (radical.pilot.raptor_tasks.Raptor method) (radical.pilot.TaskManager method) submit_workers() (radical.pilot.raptor.Master method) (radical.pilot.raptor_tasks.Raptor method) (radical.pilot.TaskManager method)

T

tags (radical.pilot.TaskDescription attribute) Task (class in radical.pilot) task_sandbox (radical.pilot.Task property) TaskDescription (class in radical.pilot)

TaskManager (class in radical.pilot) terminate() (radical.pilot.raptor.Master method) threading_type (radical.pilot.TaskDescription attribute) timeout (radical.pilot.TaskDescription attribute) tmgr (radical.pilot.Task property)

U

uid (radical.pilot.Pilot property) (radical.pilot.PilotDescription attribute) (radical.pilot.PilotManager property) (radical.pilot.Task property) (radical.pilot.TaskDescription attribute) (radical.pilot.TaskManager property)

unregister_input() (radical.pilot.utils.component.BaseComponent method) unregister_output() (radical.pilot.utils.component.BaseComponent method) unregister_timed_cb() (radical.pilot.utils.component.BaseComponent method) unschedule_cb() (radical.pilot.agent.scheduler.base.AgentSchedulingComponent method) unschedule_task() (radical.pilot.agent.scheduler.continuous.Continuous method) use_mpi (radical.pilot.TaskDescription attribute)

W

wait() (radical.pilot.Pilot method) (radical.pilot.Task method) wait_pilots() (radical.pilot.PilotManager method) wait_tasks() (radical.pilot.TaskManager method) wait_workers() (radical.pilot.raptor.Master method) work() (radical.pilot.agent.scheduler.base.AgentSchedulingComponent method)

work_cb() (radical.pilot.utils.component.BaseComponent method) Worker (class in radical.pilot.raptor) worker_class (radical.pilot.TaskDescription attribute) worker_file (radical.pilot.TaskDescription attribute) worker_state_cb() (radical.pilot.raptor.Master method) workers (radical.pilot.raptor.Master property)