Index

A

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

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

bid_to_pos (deisa.ray.types.PartialArray attribute)

Bridge (class in deisa.ray.bridge) bridge_id (deisa.ray.types.ChunkRef attribute)

C

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

D

DaskArrayData (class in deisa.ray.types) deisa module Deisa (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.ray_patch module deisa.ray.scheduling_actor module deisa.ray.types module deisa.ray.utils module deisa.ray.window_handler module delete() (deisa.ray.scheduling_actor.NodeActorBase 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

f_preprocessing (deisa.ray.types.DaskArrayData attribute)

feedback_non_chunked (deisa.ray.scheduling_actor.NodeActorBase attribute) fully_defined (deisa.ray.types.DaskArrayData attribute)

G

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.bridge) 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)

M

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

N

name (deisa.ray.types.DaskArrayData attribute) (deisa.ray.types.WindowArrayDefinition 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.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 (deisa.ray.types.ChunkRef attribute)

position_to_bridgeID (deisa.ray.types.DaskArrayData attribute) position_to_node_actorID (deisa.ray.types.DaskArrayData attribute) preprocess() (deisa.ray.types.WindowArrayDefinition method) preprocessing_callbacks (deisa.ray.bridge.Bridge attribute) preprocessing_callbacks() (deisa.ray.scheduling_actor.NodeActorBase method)

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

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

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

T

timestep (deisa.ray.types.ChunkRef attribute)

U

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

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

W

window_size (deisa.ray.types.WindowArrayDefinition attribute)

WindowArrayDefinition (class in deisa.ray.types)