Index

_

__init__() (parsl.app.futures.DataFuture method) (parsl.channels.LocalChannel method), [1], [2] (parsl.channels.OAuthSSHChannel method) (parsl.channels.SSHChannel method), [1], [2] (parsl.channels.SSHInteractiveLoginChannel method), [1], [2] (parsl.config.Config method) (parsl.data_provider.data_manager.DataManager method) (parsl.data_provider.data_manager.Staging method) (parsl.data_provider.file_noop.NoOpFileStaging method) (parsl.data_provider.files.File method) (parsl.data_provider.ftp.FTPInTaskStaging method) (parsl.data_provider.ftp.FTPSeparateTaskStaging method) (parsl.data_provider.globus.GlobusStaging method) (parsl.data_provider.http.HTTPInTaskStaging method) (parsl.data_provider.http.HTTPSeparateTaskStaging method) (parsl.data_provider.rsync.RSyncStaging method) (parsl.dataflow.dflow.DataFlowKernel method) (parsl.dataflow.dflow.DataFlowKernelLoader method) (parsl.dataflow.flow_control.Timer method) (parsl.dataflow.futures.AppFuture method) (parsl.dataflow.memoization.Memoizer method) (parsl.dataflow.strategy.Strategy method) (parsl.executors.base.ParslExecutor method), [1] (parsl.executors.ExtremeScaleExecutor method), [1] (parsl.executors.HighThroughputExecutor method), [1] (parsl.executors.swift_t.TurbineExecutor method), [1] (parsl.executors.ThreadPoolExecutor method) (parsl.executors.threads.ThreadPoolExecutor method) (parsl.executors.WorkQueueExecutor method), [1] (parsl.launchers.AprunLauncher method) (parsl.launchers.GnuParallelLauncher method) (parsl.launchers.JsrunLauncher method) (parsl.launchers.MpiExecLauncher method) (parsl.launchers.SimpleLauncher method) (parsl.launchers.SingleNodeLauncher method) (parsl.launchers.SrunLauncher method) (parsl.launchers.SrunMPILauncher method) (parsl.launchers.WrappedLauncher method) (parsl.monitoring.MonitoringHub method) (parsl.providers.AdHocProvider method) (parsl.providers.AWSProvider method), [1], [2] (parsl.providers.CobaltProvider method), [1], [2] (parsl.providers.CondorProvider method), [1], [2] (parsl.providers.GoogleCloudProvider method), [1] (parsl.providers.GridEngineProvider method), [1], [2] (parsl.providers.JetstreamProvider method) (parsl.providers.KubernetesProvider method), [1] (parsl.providers.LocalProvider method), [1], [2] (parsl.providers.LSFProvider method) (parsl.providers.PBSProProvider method) (parsl.providers.SlurmProvider method), [1], [2] (parsl.providers.TorqueProvider method), [1], [2]

__weakref__ (parsl.channels.base.Channel attribute) (parsl.dataflow.dflow.DataFlowKernel attribute) (parsl.dataflow.flow_control.Timer attribute) (parsl.dataflow.memoization.Memoizer attribute) (parsl.dataflow.strategy.Strategy attribute) (parsl.providers.provider_base.ExecutionProvider attribute) _queue_management_worker() (parsl.executors.swift_t.TurbineExecutor method) _start_local_queue_process() (parsl.executors.ExtremeScaleExecutor method) (parsl.executors.HighThroughputExecutor method) _start_queue_management_thread() (parsl.executors.ExtremeScaleExecutor method) (parsl.executors.HighThroughputExecutor method) (parsl.executors.swift_t.TurbineExecutor method) _status() (parsl.providers.CobaltProvider method) (parsl.providers.CondorProvider method) (parsl.providers.SlurmProvider method) (parsl.providers.TorqueProvider method) _write_submit_script() (parsl.providers.CobaltProvider method) (parsl.providers.CondorProvider method) (parsl.providers.SlurmProvider method) (parsl.providers.TorqueProvider method)

A

abspath() (parsl.channels.base.Channel method) (parsl.channels.LocalChannel method) (parsl.channels.SSHChannel method) address_by_hostname() (in module parsl.addresses) address_by_interface() (in module parsl.addresses) address_by_query() (in module parsl.addresses) address_by_route() (in module parsl.addresses) AdHocProvider (class in parsl.providers)

AppBadFormatting (class in parsl.app.errors) AppException (class in parsl.app.errors) AppFuture (class in parsl.dataflow.futures) AppTimeout AprunLauncher (class in parsl.launchers), [1] AuthException AWSProvider (class in parsl.providers), [1], [2]

B

BadCheckpoint BadHostKeyException BadLauncher BadMessage BadPermsScriptPath BadScriptPath

BadStdStreamFile bash_app() (in module parsl.app.app) BashApp (class in parsl.app.bash) BashAppNoReturn BashExitFailure (class in parsl.app.errors)

C

cancel() (parsl.providers.AWSProvider method), [1] (parsl.providers.CobaltProvider method), [1] (parsl.providers.CondorProvider method), [1] (parsl.providers.GoogleCloudProvider method) (parsl.providers.GridEngineProvider method), [1] (parsl.providers.KubernetesProvider method) (parsl.providers.LocalProvider method), [1] (parsl.providers.provider_base.ExecutionProvider method) (parsl.providers.SlurmProvider method), [1] (parsl.providers.TorqueProvider method), [1] Channel (class in parsl.channels.base), [1] ChannelError ChannelRequired check_memo() (parsl.dataflow.memoization.Memoizer method) checkpoint() (parsl.dataflow.dflow.DataFlowKernel method) cleanup() (parsl.dataflow.dflow.DataFlowKernel method) close() (parsl.channels.base.Channel method), [1] (parsl.channels.LocalChannel method), [1] (parsl.channels.SSHChannel method), [1] (parsl.channels.SSHInteractiveLoginChannel method) (parsl.dataflow.flow_control.FlowControl method) (parsl.dataflow.flow_control.Timer method)

CobaltProvider (class in parsl.providers), [1], [2] CondorProvider (class in parsl.providers), [1], [2] Config (class in parsl.config) config() (parsl.dataflow.dflow.DataFlowKernel property) config_route_table() (parsl.providers.AWSProvider method) ConfigurationError ControllerError cores_per_node() (parsl.providers.provider_base.ExecutionProvider property) create_session() (parsl.providers.AWSProvider method), [1] create_vpc() (parsl.providers.AWSProvider method), [1] current_capacity() (parsl.providers.AWSProvider property), [1] (parsl.providers.CobaltProvider property) (parsl.providers.CondorProvider property), [1] (parsl.providers.GridEngineProvider property) (parsl.providers.SlurmProvider property) (parsl.providers.TorqueProvider property)

D

DataFlowException (class in parsl.dataflow.error) DataFlowKernel (class in parsl.dataflow.dflow) DataFlowKernelLoader (class in parsl.dataflow.dflow) DataFuture (class in parsl.app.futures)

DataManager (class in parsl.data_provider.data_manager) DependencyError (class in parsl.dataflow.error) DeserializationError DuplicateTaskError (class in parsl.dataflow.error)

E

execute_wait() (parsl.channels.base.Channel method), [1] (parsl.channels.LocalChannel method), [1] (parsl.channels.SSHChannel method), [1] (parsl.channels.SSHInteractiveLoginChannel method)

ExecutionProvider (class in parsl.providers.provider_base) ExecutionProviderException ExecutorError ExtremeScaleExecutor (class in parsl.executors), [1]

F

File (class in parsl.data_provider.files) FileCopyException FileExists

FlowControl (class in parsl.dataflow.flow_control) FTPInTaskStaging (class in parsl.data_provider.ftp) FTPSeparateTaskStaging (class in parsl.data_provider.ftp)

G

get_configs() (parsl.providers.GridEngineProvider method) get_instance_state() (parsl.providers.AWSProvider method) GlobusStaging (class in parsl.data_provider.globus)

GnuParallelLauncher (class in parsl.launchers) GoogleCloudProvider (class in parsl.providers), [1] GridEngineProvider (class in parsl.providers), [1], [2]

H

handle_app_update() (parsl.dataflow.dflow.DataFlowKernel method) handle_exec_update() (parsl.dataflow.dflow.DataFlowKernel method) hash_lookup() (parsl.dataflow.memoization.Memoizer method) HighThroughputExecutor (class in parsl.executors), [1]

hold_worker() (parsl.executors.ExtremeScaleExecutor method) (parsl.executors.HighThroughputExecutor method) HTTPInTaskStaging (class in parsl.data_provider.http) HTTPSeparateTaskStaging (class in parsl.data_provider.http)

I

initialize_boto_client() (parsl.providers.AWSProvider method) InsufficientMPIRanks

isdir() (parsl.channels.base.Channel method) (parsl.channels.LocalChannel method) (parsl.channels.SSHChannel method)

J

JetstreamProvider (class in parsl.providers)

JsrunLauncher (class in parsl.launchers)

K

KubernetesProvider (class in parsl.providers), [1]

L

label() (parsl.providers.AWSProvider property) (parsl.providers.KubernetesProvider property) (parsl.providers.LocalProvider property) (parsl.providers.provider_base.ExecutionProvider property) launch_if_ready() (parsl.dataflow.dflow.DataFlowKernel method)

launch_task() (parsl.dataflow.dflow.DataFlowKernel method) load_checkpoints() (parsl.dataflow.dflow.DataFlowKernel method) LocalChannel (class in parsl.channels), [1], [2] LocalProvider (class in parsl.providers), [1], [2] LSFProvider (class in parsl.providers)

M

make_callback() (parsl.dataflow.flow_control.FlowControl method) (parsl.dataflow.flow_control.Timer method) make_hash() (parsl.dataflow.memoization.Memoizer method) makedirs() (parsl.channels.base.Channel method) (parsl.channels.LocalChannel method) (parsl.channels.SSHChannel method)

mem_per_node() (parsl.providers.provider_base.ExecutionProvider property) Memoizer (class in parsl.dataflow.memoization) MissingOutputs (class in parsl.app.errors) MonitoringHub (class in parsl.monitoring) MpiExecLauncher (class in parsl.launchers)

N

NoOpFileStaging (class in parsl.data_provider.file_noop) NotFutureError (class in parsl.app.errors)

notify() (parsl.dataflow.flow_control.FlowControl method)

O

OAuthSSHChannel (class in parsl.channels)

OptionalModuleMissing

P

parsl (module) ParslError (class in parsl.app.errors) ParslExecutor (class in parsl.executors.base), [1] PBSProProvider (class in parsl.providers) pull_file() (parsl.channels.base.Channel method) (parsl.channels.LocalChannel method) (parsl.channels.SSHChannel method), [1] (parsl.channels.SSHInteractiveLoginChannel method)

push_file() (parsl.channels.base.Channel method), [1] (parsl.channels.LocalChannel method), [1] (parsl.channels.SSHChannel method), [1] (parsl.channels.SSHInteractiveLoginChannel method) python_app() (in module parsl.app.app) PythonApp (class in parsl.app.python)

R

read_state_file() (parsl.providers.AWSProvider method), [1] RSyncStaging (class in parsl.data_provider.rsync)

run_dir() (parsl.executors.WorkQueueExecutor method) runner() (in module parsl.executors.swift_t)

S

sanitize_and_wrap() (parsl.dataflow.dflow.DataFlowKernel method) scale_in() (parsl.executors.base.ParslExecutor method) (parsl.executors.ExtremeScaleExecutor method) (parsl.executors.HighThroughputExecutor method) (parsl.executors.swift_t.TurbineExecutor method) (parsl.executors.threads.ThreadPoolExecutor method) (parsl.executors.WorkQueueExecutor method) scale_out() (parsl.executors.base.ParslExecutor method) (parsl.executors.ExtremeScaleExecutor method) (parsl.executors.HighThroughputExecutor method) (parsl.executors.swift_t.TurbineExecutor method) (parsl.executors.threads.ThreadPoolExecutor method) (parsl.executors.WorkQueueExecutor method) ScaleOutFailed scaling_enabled() (parsl.executors.base.ParslExecutor property) (parsl.executors.ExtremeScaleExecutor property) (parsl.executors.HighThroughputExecutor property) (parsl.executors.threads.ThreadPoolExecutor property) (parsl.executors.WorkQueueExecutor method) ScalingFailed SchedulerMissingArgs script_dir() (parsl.channels.base.Channel property), [1] (parsl.channels.LocalChannel property), [1] (parsl.channels.SSHChannel property), [1] (parsl.channels.SSHInteractiveLoginChannel property) ScriptPathError security_group() (parsl.providers.AWSProvider method), [1] set_file_logger() (in module parsl) set_stream_logger() (in module parsl) show_summary() (parsl.providers.AWSProvider method) shut_down_instance() (parsl.providers.AWSProvider method) shutdown() (parsl.executors.swift_t.TurbineExecutor method) (parsl.executors.WorkQueueExecutor method) SimpleLauncher (class in parsl.launchers), [1] SingleNodeLauncher (class in parsl.launchers), [1] SlurmProvider (class in parsl.providers), [1], [2] spin_up_instance() (parsl.providers.AWSProvider method) SrunLauncher (class in parsl.launchers), [1] SrunMPILauncher (class in parsl.launchers), [1] SSHChannel (class in parsl.channels), [1], [2] SSHException SSHInteractiveLoginChannel (class in parsl.channels), [1], [2]

Staging (class in parsl.data_provider.data_manager) start() (parsl.executors.ExtremeScaleExecutor method) (parsl.executors.HighThroughputExecutor method) (parsl.executors.threads.ThreadPoolExecutor method) (parsl.executors.WorkQueueExecutor method) status() (parsl.providers.AWSProvider method), [1] (parsl.providers.CobaltProvider method) (parsl.providers.CondorProvider method), [1] (parsl.providers.GoogleCloudProvider method) (parsl.providers.GridEngineProvider method) (parsl.providers.KubernetesProvider method) (parsl.providers.LocalProvider method), [1] (parsl.providers.provider_base.ExecutionProvider method) (parsl.providers.SlurmProvider method) (parsl.providers.TorqueProvider method) status_polling_interval() (parsl.providers.AWSProvider property) (parsl.providers.CobaltProvider property) (parsl.providers.CondorProvider property) (parsl.providers.GridEngineProvider property) (parsl.providers.KubernetesProvider property) (parsl.providers.LocalProvider property) (parsl.providers.provider_base.ExecutionProvider property) (parsl.providers.SlurmProvider property) (parsl.providers.TorqueProvider property) Strategy (class in parsl.dataflow.strategy) submit() (parsl.dataflow.dflow.DataFlowKernel method) (parsl.executors.base.ParslExecutor method) (parsl.executors.ExtremeScaleExecutor method) (parsl.executors.HighThroughputExecutor method) (parsl.executors.swift_t.TurbineExecutor method) (parsl.executors.threads.ThreadPoolExecutor method) (parsl.executors.WorkQueueExecutor method) (parsl.providers.AWSProvider method), [1] (parsl.providers.CobaltProvider method), [1] (parsl.providers.CondorProvider method), [1] (parsl.providers.GoogleCloudProvider method) (parsl.providers.GridEngineProvider method), [1] (parsl.providers.KubernetesProvider method) (parsl.providers.LocalProvider method), [1] (parsl.providers.provider_base.ExecutionProvider method) (parsl.providers.SlurmProvider method), [1] (parsl.providers.TorqueProvider method), [1]

T

teardown() (parsl.providers.AWSProvider method) ThreadPoolExecutor (class in parsl.executors) (class in parsl.executors.threads)

Timer (class in parsl.dataflow.flow_control) TorqueProvider (class in parsl.providers), [1], [2] TurbineExecutor (class in parsl.executors.swift_t), [1]

U

unset_logging() (parsl.dataflow.strategy.Strategy method)

update_memo() (parsl.dataflow.memoization.Memoizer method)

W

wait_for_current_tasks() (parsl.dataflow.dflow.DataFlowKernel method) wipe_task() (parsl.dataflow.dflow.DataFlowKernel method) WorkerLost

WorkQueueExecutor (class in parsl.executors), [1] WrappedLauncher (class in parsl.launchers), [1] write_state_file() (parsl.providers.AWSProvider method), [1]