Index

A

actor_handle (deisa.ray.scheduling_actor.NodeActorBase attribute) actor_id (deisa.ray.scheduling_actor.NodeActorBase attribute)

add_chunk() (deisa.ray.scheduling_actor.NodeActorBase method) add_chunk_ref() (deisa.ray.types.DaskArrayData method) ArrayPerTimestep (class in deisa.ray.types)

B

bid_to_pos (deisa.ray.types.PartialArray attribute)

Bridge (class in deisa.ray) (class in deisa.ray.bridge)

C

chunk_fname() (in module deisa.ray.types) chunk_refs (deisa.ray.types.DaskArrayData attribute) ChunkRef (class in deisa.ray.types) chunks_contained_meta (deisa.ray.types.PartialArray attribute) chunks_ready_event (deisa.ray.types.ArrayPerTimestep attribute)

chunks_size (deisa.ray.types.DaskArrayData attribute) close() (deisa.ray.Bridge method) (deisa.ray.bridge.Bridge method) ConfigError ContractError create_vds() (in module deisa.ray.types)

D

DaskArrayData (class in deisa.ray.types) Deisa (class in deisa.ray) (class in deisa.ray.window_handler) deisa.ray module deisa.ray.bridge 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) distributed_scheduling_enabled_from_env() (in module deisa.ray.config) dtype (deisa.ray.types.ArrayPerTimestep attribute) dtype_by_timestep (deisa.ray.types.DaskArrayData attribute)

E

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

F

feedback (deisa.ray.scheduling_actor.NodeActorBase attribute)

finalize_registration() (deisa.ray.scheduling_actor.NodeActorBase method) fully_defined (deisa.ray.types.DaskArrayData attribute)

G

get() (deisa.ray.Bridge method) (deisa.ray.bridge.Bridge 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_ray_address() (in module deisa.ray.utils) get_ready_actor_with_retry() (in module deisa.ray.utils) GraphInfo (class in deisa.ray.types)

H

head (deisa.ray.scheduling_actor.NodeActorBase attribute)

L

local_chunks (deisa.ray.types.ArrayPerTimestep attribute)

log() (in module deisa.ray.utils)

M

module deisa.ray deisa.ray.bridge 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

N

name (deisa.ray.types.DaskArrayData attribute) nb_chunks (deisa.ray.types.DaskArrayData attribute) nb_chunks_per_dim (deisa.ray.types.DaskArrayData attribute)

nb_scheduling_actors (deisa.ray.types.DaskArrayData attribute) node_id (deisa.ray.Bridge attribute) (deisa.ray.bridge.Bridge attribute) NodeActorBase (class in deisa.ray.scheduling_actor)

P

partial_arrays (deisa.ray.scheduling_actor.NodeActorBase attribute) PartialArray (class in deisa.ray.types) per_timestep_arrays (deisa.ray.types.PartialArray attribute)

pos_to_ref_by_timestep (deisa.ray.types.DaskArrayData attribute) position_to_bridgeID (deisa.ray.types.DaskArrayData attribute) position_to_node_actorID (deisa.ray.types.DaskArrayData attribute)

R

ready() (deisa.ray.scheduling_actor.NodeActorBase method) ready_event (deisa.ray.types.PartialArray attribute) refs (deisa.ray.types.GraphInfo attribute) register() (deisa.ray.Deisa method) (deisa.ray.window_handler.Deisa method)

register_callback() (deisa.ray.Deisa method) (deisa.ray.window_handler.Deisa method) register_chunk_meta() (deisa.ray.scheduling_actor.NodeActorBase method)

S

save_chunk() (in module deisa.ray.types) scheduled_event (deisa.ray.types.GraphInfo attribute) ScheduledByOtherActor (class in deisa.ray.types)

send() (deisa.ray.Bridge method) (deisa.ray.bridge.Bridge method) set() (deisa.ray.Deisa method) (deisa.ray.window_handler.Deisa method)

T

timestep (deisa.ray.types.DeisaArray property) to_hdf5() (deisa.ray.types.DeisaArray method) (in module deisa.ray.types)

to_zarr() (deisa.ray.types.DeisaArray method)

U

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

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

W

Window (class in deisa.ray.types)