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)

C

callback() (deisa.ray.window_handler.Deisa method) 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) Config (class in deisa.ray.config) ConfigError ContractError create_vds() (in module deisa.ray.types)

D

DaskArrayData (class in deisa.ray.types) Deisa (class in deisa.ray.window_handler) deisa.ray 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) dtype (deisa.ray.types.DaskArrayData attribute)

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)

G

generate_queue_per_array() (deisa.ray.window_handler.Deisa method) get() (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)

H

head (deisa.ray.scheduling_actor.NodeActorBase attribute)

I

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.ray 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) 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_callback() (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)

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

T

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

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

U

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

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

W

WindowSpec (class in deisa.ray.types)