Index

A

actor_handle (deisa.ray.scheduling_actor.NodeActorBase attribute) actor_id (deisa.ray.scheduling_actor.NodeActorBase attribute) (deisa.ray.types.ScheduledByOtherActor attribute) actorid (deisa.ray.types.ChunkRef attribute)

ActorID (in module deisa.ray.types) add_chunk() (deisa.ray.scheduling_actor.NodeActorBase method) add_chunk_ref() (deisa.ray.types.DaskArrayData method) array_name (deisa.ray.types.ChunkRef attribute) ArrayPerTimestep (class in deisa.ray.types)

B

barrier() (deisa.ray.comm.Comm method) (deisa.ray.comm.MPICommAdapter method) (deisa.ray.comm.NoOpComm method) (deisa.ray.comm.TorchDistComm method)

bid_to_pos (deisa.ray.types.PartialArray attribute), [1] Bridge (class in deisa.ray.bridge) bridge_id (deisa.ray.types.ChunkRef attribute)

C

callback() (deisa.ray.window_handler.Deisa method) chunk_refs (deisa.ray.types.DaskArrayData attribute), [1] ChunkRef (class in deisa.ray.types) chunks_contained_meta (deisa.ray.types.PartialArray attribute), [1] chunks_ready_event (deisa.ray.types.ArrayPerTimestep attribute)

chunks_size (deisa.ray.types.DaskArrayData attribute), [1] close() (deisa.ray.bridge.Bridge method) Comm (class in deisa.ray.comm) Config (class in deisa.ray.config) ConfigError ContractError

D

dask (deisa.ray.types.DeisaArray attribute) DaskArrayData (class in deisa.ray.types) deisa module Deisa (class in deisa.ray.window_handler) deisa.ray module deisa.ray.bridge module deisa.ray.comm module deisa.ray.config module deisa.ray.errors module deisa.ray.head_node module

deisa.ray.scheduling_actor module deisa.ray.types module deisa.ray.utils module deisa.ray.validate module deisa.ray.window_handler module DeisaArray (class in deisa.ray.types) delete() (deisa.ray.scheduling_actor.NodeActorBase method) determine_callback_args() (deisa.ray.window_handler.Deisa method) DoubleRef (in module deisa.ray.types) dtype (deisa.ray.types.DaskArrayData attribute), [1]

E

enable_experimental_distributed_scheduling() (deisa.ray.config.Config method)

execute_callbacks() (deisa.ray.window_handler.Deisa method) experimental_distributed_scheduling_enabled (deisa.ray.config.Config property)

F

feedback_non_chunked (deisa.ray.scheduling_actor.NodeActorBase attribute)

fully_defined (deisa.ray.types.DaskArrayData attribute), [1]

G

generate_queue_per_array() (deisa.ray.window_handler.Deisa method) get() (deisa.ray.bridge.Bridge method) (deisa.ray.scheduling_actor.NodeActorBase method) get_full_array() (deisa.ray.types.DaskArrayData method) get_head_actor_options() (in module deisa.ray.utils) get_head_node_id() (in module deisa.ray.utils)

get_node_actor_options() (in module deisa.ray.utils) get_ready_actor_with_retry() (in module deisa.ray.utils) get_system_metadata() (in module deisa.ray.utils) GraphInfo (class in deisa.ray.types) GraphKey (in module deisa.ray.types) GraphValue (in module deisa.ray.types)

H

head (deisa.ray.scheduling_actor.NodeActorBase attribute)

I

init_gloo_comm() (in module deisa.ray.comm)

is_locked() (deisa.ray.config.Config method)

L

local_chunks (deisa.ray.types.ArrayPerTimestep attribute)

lock() (deisa.ray.config.Config method) log() (in module deisa.ray.utils)

M

module deisa deisa.ray deisa.ray.bridge deisa.ray.comm deisa.ray.config deisa.ray.errors deisa.ray.head_node deisa.ray.scheduling_actor deisa.ray.types deisa.ray.utils deisa.ray.validate deisa.ray.window_handler

MPICommAdapter (class in deisa.ray.comm)

N

name (deisa.ray.types.DaskArrayData attribute) (deisa.ray.types.WindowSpec attribute) nb_chunks (deisa.ray.types.DaskArrayData attribute), [1] nb_chunks_per_dim (deisa.ray.types.DaskArrayData attribute), [1]

nb_scheduling_actors (deisa.ray.types.DaskArrayData attribute), [1] node_id (deisa.ray.bridge.Bridge attribute) NodeActorBase (class in deisa.ray.scheduling_actor) NoOpComm (class in deisa.ray.comm)

P

partial_arrays (deisa.ray.scheduling_actor.NodeActorBase attribute) PartialArray (class in deisa.ray.types) per_timestep_arrays (deisa.ray.types.PartialArray attribute), [1]

pos_to_ref_by_timestep (deisa.ray.types.DaskArrayData attribute), [1] position_to_bridgeID (deisa.ray.types.DaskArrayData attribute), [1] position_to_node_actorID (deisa.ray.types.DaskArrayData attribute), [1]

R

rank (deisa.ray.comm.Comm attribute) ready() (deisa.ray.scheduling_actor.NodeActorBase method) ready_event (deisa.ray.types.PartialArray attribute)

ref (deisa.ray.types.ChunkRef attribute) refs (deisa.ray.types.GraphInfo attribute), [1] register_callback() (deisa.ray.window_handler.Deisa method) register_chunk_meta() (deisa.ray.scheduling_actor.NodeActorBase method)

S

scheduled_event (deisa.ray.types.GraphInfo attribute) ScheduledByOtherActor (class in deisa.ray.types) send() (deisa.ray.bridge.Bridge method)

set() (deisa.ray.scheduling_actor.NodeActorBase method) (deisa.ray.window_handler.Deisa method) should_call() (deisa.ray.window_handler.Deisa method)

T

t (deisa.ray.types.DeisaArray attribute)

timestep (deisa.ray.types.ChunkRef attribute) TorchDistComm (class in deisa.ray.comm)

U

unregister_callback() (deisa.ray.window_handler.Deisa method)

update_meta() (deisa.ray.types.DaskArrayData method)

W

window_size (deisa.ray.types.WindowSpec attribute)

WindowSpec (class in deisa.ray.types) world_size (deisa.ray.comm.Comm attribute)