Index

_

__init__() (parsl.app.app.AppBase method) (parsl.app.bash.BashApp method) (parsl.app.futures.DataFuture method) (parsl.app.python.PythonApp method) (parsl.channels.base.Channel method) (parsl.channels.LocalChannel method) (parsl.channels.OAuthSSHChannel method) (parsl.channels.SSHChannel method) (parsl.channels.SSHInteractiveLoginChannel method) (parsl.config.Config method) (parsl.data_provider.data_manager.DataManager 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.data_provider.staging.Staging method) (parsl.dataflow.dflow.DataFlowKernel method) (parsl.dataflow.dflow.DataFlowKernelLoader method) (parsl.dataflow.futures.AppFuture method) (parsl.dataflow.job_status_poller.JobStatusPoller method) (parsl.dataflow.memoization.Memoizer method) (parsl.dataflow.states.States method) (parsl.dataflow.strategy.Strategy method) (parsl.dataflow.taskrecord.TaskRecord method) (parsl.executors.base.ParslExecutor method) (parsl.executors.FluxExecutor method) (parsl.executors.HighThroughputExecutor method) (parsl.executors.status_handling.BlockProviderExecutor method) (parsl.executors.swift_t.TurbineExecutor method) (parsl.executors.ThreadPoolExecutor method) (parsl.executors.WorkQueueExecutor method) (parsl.launchers.AprunLauncher method) (parsl.launchers.GnuParallelLauncher method) (parsl.launchers.JsrunLauncher method) (parsl.launchers.launchers.Launcher 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) (parsl.providers.base.ExecutionProvider method) (parsl.providers.cluster_provider.ClusterProvider method) (parsl.providers.CobaltProvider method) (parsl.providers.CondorProvider method) (parsl.providers.GoogleCloudProvider method) (parsl.providers.GridEngineProvider method) (parsl.providers.KubernetesProvider method) (parsl.providers.LocalProvider method) (parsl.providers.LSFProvider method) (parsl.providers.PBSProProvider method) (parsl.providers.SlurmProvider method) (parsl.providers.TorqueProvider method) (parsl.utils.Timer method)

A

abspath() (parsl.channels.base.Channel method) (parsl.channels.LocalChannel method) (parsl.channels.SSHChannel method) add_executors() (parsl.dataflow.dflow.DataFlowKernel method) (parsl.dataflow.job_status_poller.JobStatusPoller method) (parsl.dataflow.strategy.Strategy 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)

app_fu (parsl.dataflow.taskrecord.TaskRecord attribute) AppBadFormatting AppBase (class in parsl.app.app) AppException AppFuture (class in parsl.dataflow.futures) AppTimeout AprunLauncher (class in parsl.launchers) args (parsl.dataflow.taskrecord.TaskRecord attribute) atexit_cleanup() (parsl.dataflow.dflow.DataFlowKernel method) AuthException AWSProvider (class in parsl.providers)

B

bad_state_is_set (parsl.executors.base.ParslExecutor property) (parsl.executors.status_handling.BlockProviderExecutor property) BadCheckpoint BadHostKeyException BadLauncher BadMessage BadPermsScriptPath

BadScriptPath BadStdStreamFile bash_app() (in module parsl.app.app) BashApp (class in parsl.app.bash) BashAppNoReturn BashExitFailure BlockProviderExecutor (class in parsl.executors.status_handling) bye() (parsl.providers.GoogleCloudProvider method)

C

can_stage_in() (parsl.data_provider.file_noop.NoOpFileStaging 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.data_provider.staging.Staging method) can_stage_out() (parsl.data_provider.file_noop.NoOpFileStaging method) (parsl.data_provider.globus.GlobusStaging method) (parsl.data_provider.rsync.RSyncStaging method) (parsl.data_provider.staging.Staging method) cancel() (parsl.app.futures.DataFuture method) (parsl.dataflow.futures.AppFuture method) (parsl.providers.AdHocProvider method) (parsl.providers.AWSProvider method) (parsl.providers.base.ExecutionProvider method) (parsl.providers.CobaltProvider method) (parsl.providers.CondorProvider method) (parsl.providers.GoogleCloudProvider method) (parsl.providers.GridEngineProvider method) (parsl.providers.KubernetesProvider method) (parsl.providers.LocalProvider method) (parsl.providers.LSFProvider method) (parsl.providers.SlurmProvider method) (parsl.providers.TorqueProvider method) cancelled() (parsl.app.futures.DataFuture method) (parsl.dataflow.futures.AppFuture method) Channel (class in parsl.channels.base)

ChannelError check_memo() (parsl.dataflow.memoization.Memoizer method) check_staging_inhibited() (parsl.dataflow.dflow.DataFlowKernel static method) checkpoint (parsl.dataflow.taskrecord.TaskRecord attribute) checkpoint() (parsl.dataflow.dflow.DataFlowKernel method) cleancopy() (parsl.data_provider.files.File method) cleanup() (parsl.dataflow.dflow.DataFlowKernel method) clear() (parsl.dataflow.dflow.DataFlowKernelLoader class method) close() (parsl.channels.base.Channel method) (parsl.channels.LocalChannel method) (parsl.channels.OAuthSSHChannel method) (parsl.channels.SSHChannel method) (parsl.monitoring.MonitoringHub method) (parsl.utils.Timer method) ClusterProvider (class in parsl.providers.cluster_provider) CobaltProvider (class in parsl.providers) CondorProvider (class in parsl.providers) Config (class in parsl.config) config (parsl.dataflow.dflow.DataFlowKernel property) config_route_table() (parsl.providers.AWSProvider method) ConfigurationError connected_managers() (parsl.executors.HighThroughputExecutor method) connected_workers (parsl.executors.HighThroughputExecutor property) cores_per_node (parsl.providers.base.ExecutionProvider property) create_instance() (parsl.providers.GoogleCloudProvider method) create_monitoring_info() (parsl.executors.base.ParslExecutor method) (parsl.executors.HighThroughputExecutor method) create_name_tag_spec() (parsl.providers.AWSProvider method) create_session() (parsl.providers.AWSProvider method) create_vpc() (parsl.providers.AWSProvider method)

D

DataFlowException 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) DEFAULT_LAUNCH_CMD (parsl.executors.FluxExecutor attribute)

delete_instance() (parsl.providers.GoogleCloudProvider method) dep_fail (parsl.dataflow.states.States attribute) DependencyError depends (parsl.dataflow.taskrecord.TaskRecord attribute) DeserializationError dfk() (parsl.dataflow.dflow.DataFlowKernelLoader class method)

E

error_management_enabled (parsl.executors.base.ParslExecutor property) (parsl.executors.status_handling.BlockProviderExecutor property) exec_done (parsl.dataflow.states.States attribute) exec_fu (parsl.dataflow.taskrecord.TaskRecord attribute) execute_wait() (parsl.channels.base.Channel method) (parsl.channels.LocalChannel method) (parsl.channels.OAuthSSHChannel method) (parsl.channels.SSHChannel method) (parsl.providers.cluster_provider.ClusterProvider method)

ExecutionProvider (class in parsl.providers.base) ExecutionProviderException executor (parsl.dataflow.taskrecord.TaskRecord attribute) executor_exception (parsl.executors.base.ParslExecutor property) (parsl.executors.status_handling.BlockProviderExecutor property) ExecutorError executors (parsl.config.Config property)

F

fail_cost (parsl.dataflow.taskrecord.TaskRecord attribute) fail_count (parsl.dataflow.taskrecord.TaskRecord attribute) fail_history (parsl.dataflow.taskrecord.TaskRecord attribute) fail_retryable (parsl.dataflow.states.States attribute) failed (parsl.dataflow.states.States attribute) File (class in parsl.data_provider.files) FileCopyException FileExists filename (parsl.app.futures.DataFuture property)

filepath (parsl.app.futures.DataFuture property) (parsl.data_provider.files.File property) FINAL_STATES (in module parsl.dataflow.states) FluxExecutor (class in parsl.executors) fn_hash (parsl.dataflow.taskrecord.TaskRecord attribute) from_memo (parsl.dataflow.taskrecord.TaskRecord attribute) FTPInTaskStaging (class in parsl.data_provider.ftp) FTPSeparateTaskStaging (class in parsl.data_provider.ftp) func (parsl.dataflow.taskrecord.TaskRecord attribute) func_name (parsl.dataflow.taskrecord.TaskRecord attribute)

G

generate_aws_id() (parsl.providers.AWSProvider method) get_all_checkpoints() (in module parsl.utils) get_configs() (parsl.providers.GridEngineProvider method) get_instance_state() (parsl.providers.AWSProvider method) get_last_checkpoint() (in module parsl.utils)

get_zone() (parsl.providers.GoogleCloudProvider method) GlobusStaging (class in parsl.data_provider.globus) GnuParallelLauncher (class in parsl.launchers) goodbye() (parsl.providers.AWSProvider method) GoogleCloudProvider (class in parsl.providers) GridEngineProvider (class in parsl.providers)

H

handle_app_update() (parsl.dataflow.dflow.DataFlowKernel method) handle_errors() (parsl.executors.base.ParslExecutor method) (parsl.executors.status_handling.BlockProviderExecutor method) handle_exec_update() (parsl.dataflow.dflow.DataFlowKernel method) handle_join_update() (parsl.dataflow.dflow.DataFlowKernel method) hash_lookup() (parsl.dataflow.memoization.Memoizer method)

hashsum (parsl.dataflow.taskrecord.TaskRecord attribute) HighThroughputExecutor (class in parsl.executors) hold_worker() (parsl.executors.HighThroughputExecutor method) HTTPInTaskStaging (class in parsl.data_provider.http) HTTPSeparateTaskStaging (class in parsl.data_provider.http) hub_address (parsl.executors.base.ParslExecutor property) hub_port (parsl.executors.base.ParslExecutor property)

I

id (parsl.dataflow.taskrecord.TaskRecord attribute) id_for_memo() (in module parsl.dataflow.memoization) ignore_for_cache (parsl.dataflow.taskrecord.TaskRecord attribute) initialize_boto_client() (parsl.providers.AWSProvider method) initialize_globus() (parsl.data_provider.globus.GlobusStaging method)

initialize_scaling() (parsl.executors.HighThroughputExecutor method) (parsl.executors.WorkQueueExecutor method) isdir() (parsl.channels.base.Channel method) (parsl.channels.LocalChannel method) (parsl.channels.SSHChannel method)

J

JobStatusPoller (class in parsl.dataflow.job_status_poller) join (parsl.dataflow.taskrecord.TaskRecord attribute) join_app() (in module parsl.app.app) join_lock (parsl.dataflow.taskrecord.TaskRecord attribute)

JoinError joining (parsl.dataflow.states.States attribute) joins (parsl.dataflow.taskrecord.TaskRecord attribute) JsrunLauncher (class in parsl.launchers)

K

KubernetesProvider (class in parsl.providers)

kwargs (parsl.dataflow.taskrecord.TaskRecord attribute)

L

label (parsl.executors.base.ParslExecutor attribute) (parsl.providers.AdHocProvider property) (parsl.providers.AWSProvider property) (parsl.providers.base.ExecutionProvider property) (parsl.providers.cluster_provider.ClusterProvider property) (parsl.providers.KubernetesProvider property) (parsl.providers.LocalProvider property) launch_if_ready() (parsl.dataflow.dflow.DataFlowKernel method)

launch_task() (parsl.dataflow.dflow.DataFlowKernel method) launched (parsl.dataflow.states.States attribute) Launcher (class in parsl.launchers.launchers) load() (parsl.dataflow.dflow.DataFlowKernelLoader class method) load_checkpoints() (parsl.dataflow.dflow.DataFlowKernel method) LocalChannel (class in parsl.channels) LocalProvider (class in parsl.providers) log_task_states() (parsl.dataflow.dflow.DataFlowKernel method) LSFProvider (class in parsl.providers)

M

make_callback() (parsl.utils.Timer method) make_hash() (parsl.dataflow.memoization.Memoizer method) makedirs() (parsl.channels.base.Channel method) (parsl.channels.LocalChannel method) (parsl.channels.SSHChannel method) ManagerLost mem_per_node (parsl.providers.base.ExecutionProvider property) memo_done (parsl.dataflow.states.States attribute)

memoize (parsl.dataflow.taskrecord.TaskRecord attribute) Memoizer (class in parsl.dataflow.memoization) MissingOutputs monitor_resources() (parsl.executors.base.ParslExecutor method) (parsl.executors.ThreadPoolExecutor method) monitor_wrapper() (parsl.monitoring.MonitoringHub static method) MonitoringHub (class in parsl.monitoring) MpiExecLauncher (class in parsl.launchers)

N

NoOpFileStaging (class in parsl.data_provider.file_noop)

O

OAuthSSHChannel (class in parsl.channels) optionally_stage_in() (parsl.data_provider.data_manager.DataManager method) OptionalModuleMissing

outputs (parsl.dataflow.futures.AppFuture property) outstanding (parsl.executors.HighThroughputExecutor property) (parsl.executors.status_handling.BlockProviderExecutor property) (parsl.executors.WorkQueueExecutor property)

P

parent_callback() (parsl.app.futures.DataFuture method) ParslError ParslExecutor (class in parsl.executors.base) PBSProProvider (class in parsl.providers) pending (parsl.dataflow.states.States attribute) poll() (parsl.dataflow.job_status_poller.JobStatusPoller method) prepend_envs() (parsl.channels.SSHChannel method) provider (parsl.executors.status_handling.BlockProviderExecutor property)

pull_file() (parsl.channels.base.Channel method) (parsl.channels.LocalChannel method) (parsl.channels.SSHChannel method) push_file() (parsl.channels.base.Channel method) (parsl.channels.LocalChannel method) (parsl.channels.SSHChannel method) python_app() (in module parsl.app.app) PythonApp (class in parsl.app.python)

R

radio_mode (parsl.executors.base.ParslExecutor attribute) (parsl.executors.HighThroughputExecutor attribute) (parsl.executors.WorkQueueExecutor attribute) read_state_file() (parsl.providers.AWSProvider method) replace_task() (parsl.data_provider.data_manager.DataManager method) (parsl.data_provider.ftp.FTPInTaskStaging method) (parsl.data_provider.http.HTTPInTaskStaging method) (parsl.data_provider.rsync.RSyncStaging method) (parsl.data_provider.staging.Staging method)

replace_task_stage_out() (parsl.data_provider.data_manager.DataManager method) (parsl.data_provider.rsync.RSyncStaging method) (parsl.data_provider.staging.Staging method) resource_specification (parsl.dataflow.taskrecord.TaskRecord attribute) retries_left (parsl.dataflow.taskrecord.TaskRecord attribute) RSyncStaging (class in parsl.data_provider.rsync) run_dir (parsl.executors.base.ParslExecutor property) running (parsl.dataflow.states.States attribute) running() (parsl.app.futures.DataFuture method) running_ended (parsl.dataflow.states.States attribute)

S

scale_in() (parsl.executors.base.ParslExecutor method) (parsl.executors.FluxExecutor method) (parsl.executors.HighThroughputExecutor method) (parsl.executors.swift_t.TurbineExecutor method) (parsl.executors.ThreadPoolExecutor method) (parsl.executors.WorkQueueExecutor method) scale_out() (parsl.executors.base.ParslExecutor method) (parsl.executors.FluxExecutor method) (parsl.executors.status_handling.BlockProviderExecutor method) (parsl.executors.swift_t.TurbineExecutor method) (parsl.executors.ThreadPoolExecutor method) ScaleOutFailed ScalingFailed SchedulerMissingArgs script_dir (parsl.channels.base.Channel property) (parsl.channels.LocalChannel property) (parsl.channels.SSHChannel property) ScriptPathError security_group() (parsl.providers.AWSProvider method) send() (parsl.monitoring.MonitoringHub method) SerializationError set_bad_state_and_fail_all() (parsl.executors.base.ParslExecutor method) (parsl.executors.status_handling.BlockProviderExecutor method) 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.base.ParslExecutor method) (parsl.executors.FluxExecutor method) (parsl.executors.HighThroughputExecutor method) (parsl.executors.swift_t.TurbineExecutor method) (parsl.executors.ThreadPoolExecutor method) (parsl.executors.WorkQueueExecutor method) SimpleLauncher (class in parsl.launchers) SingleNodeLauncher (class in parsl.launchers) SlurmProvider (class in parsl.providers) spin_up_instance() (parsl.providers.AWSProvider method) SrunLauncher (class in parsl.launchers) SrunMPILauncher (class in parsl.launchers) SSHChannel (class in parsl.channels) SSHException SSHInteractiveLoginChannel (class in parsl.channels) stage_in() (parsl.data_provider.data_manager.DataManager 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.data_provider.staging.Staging method) stage_out() (parsl.data_provider.data_manager.DataManager method) (parsl.data_provider.globus.GlobusStaging method) (parsl.data_provider.rsync.RSyncStaging method) (parsl.data_provider.staging.Staging method) Staging (class in parsl.data_provider.staging) start() (parsl.executors.base.ParslExecutor method) (parsl.executors.FluxExecutor method) (parsl.executors.HighThroughputExecutor method) (parsl.executors.swift_t.TurbineExecutor method) (parsl.executors.ThreadPoolExecutor method) (parsl.executors.WorkQueueExecutor method) (parsl.monitoring.MonitoringHub method)

States (class in parsl.dataflow.states) status (parsl.dataflow.taskrecord.TaskRecord attribute) status() (parsl.executors.base.ParslExecutor method) (parsl.executors.status_handling.BlockProviderExecutor method) (parsl.providers.AdHocProvider method) (parsl.providers.AWSProvider method) (parsl.providers.base.ExecutionProvider method) (parsl.providers.cluster_provider.ClusterProvider method) (parsl.providers.CondorProvider method) (parsl.providers.GoogleCloudProvider method) (parsl.providers.KubernetesProvider method) (parsl.providers.LocalProvider method) status_polling_interval (parsl.executors.base.ParslExecutor property) (parsl.executors.status_handling.BlockProviderExecutor property) (parsl.providers.AdHocProvider property) (parsl.providers.AWSProvider property) (parsl.providers.base.ExecutionProvider property) (parsl.providers.CobaltProvider property) (parsl.providers.CondorProvider property) (parsl.providers.GoogleCloudProvider property) (parsl.providers.GridEngineProvider property) (parsl.providers.KubernetesProvider property) (parsl.providers.LocalProvider property) (parsl.providers.LSFProvider property) (parsl.providers.PBSProProvider property) (parsl.providers.SlurmProvider property) (parsl.providers.TorqueProvider property) stderr (parsl.dataflow.futures.AppFuture property) stdout (parsl.dataflow.futures.AppFuture property) Strategy (class in parsl.dataflow.strategy) submit() (parsl.dataflow.dflow.DataFlowKernel method) (parsl.executors.base.ParslExecutor method) (parsl.executors.FluxExecutor method) (parsl.executors.HighThroughputExecutor method) (parsl.executors.swift_t.TurbineExecutor method) (parsl.executors.ThreadPoolExecutor method) (parsl.executors.WorkQueueExecutor method) (parsl.providers.AdHocProvider method) (parsl.providers.AWSProvider method) (parsl.providers.base.ExecutionProvider method) (parsl.providers.CobaltProvider method) (parsl.providers.CondorProvider method) (parsl.providers.GoogleCloudProvider method) (parsl.providers.GridEngineProvider method) (parsl.providers.KubernetesProvider method) (parsl.providers.LocalProvider method) (parsl.providers.LSFProvider method) (parsl.providers.PBSProProvider method) (parsl.providers.SlurmProvider method) (parsl.providers.TorqueProvider method)

T

task_launch_lock (parsl.dataflow.taskrecord.TaskRecord attribute) task_status() (parsl.dataflow.futures.AppFuture method) TaskRecord (class in parsl.dataflow.taskrecord) tasks (parsl.executors.status_handling.BlockProviderExecutor property) teardown() (parsl.providers.AWSProvider method) ThreadPoolExecutor (class in parsl.executors) tid (parsl.app.futures.DataFuture property) (parsl.dataflow.futures.AppFuture property)

time_invoked (parsl.dataflow.taskrecord.TaskRecord attribute) time_returned (parsl.dataflow.taskrecord.TaskRecord attribute) Timer (class in parsl.utils) TorqueProvider (class in parsl.providers) try_id (parsl.dataflow.taskrecord.TaskRecord attribute) try_time_launched (parsl.dataflow.taskrecord.TaskRecord attribute) try_time_returned (parsl.dataflow.taskrecord.TaskRecord attribute) TurbineExecutor (class in parsl.executors.swift_t)

U

unsched (parsl.dataflow.states.States attribute)

update_memo() (parsl.dataflow.memoization.Memoizer method) update_task_state() (parsl.dataflow.dflow.DataFlowKernel method)

W

wait_for_current_tasks() (parsl.dataflow.dflow.DataFlowKernel method) (parsl.dataflow.dflow.DataFlowKernelLoader class method) weakref_cb() (parsl.executors.swift_t.TurbineExecutor method) wipe_task() (parsl.dataflow.dflow.DataFlowKernel method) WorkerLost

workers_per_node (parsl.executors.HighThroughputExecutor property) (parsl.executors.status_handling.BlockProviderExecutor property) (parsl.executors.WorkQueueExecutor property) WorkQueueExecutor (class in parsl.executors) WrappedLauncher (class in parsl.launchers) write_state_file() (parsl.providers.AWSProvider method)

X

xstr() (parsl.providers.AWSProvider method)