deisa.ray package

Submodules

• deisa.ray.bridge module
  • Bridge
    • Bridge.node_id
    • Bridge.scheduling_actor
    • Bridge.preprocessing_callbacks
    • Bridge.get()
    • Bridge.send()
  • get_node_actor_options()
• deisa.ray.config module
  • Config
    • Config.enable_experimental_distributed_scheduling()
    • Config.experimental_distributed_scheduling_enabled
    • Config.is_locked()
    • Config.lock()
• deisa.ray.errors module
  • ConfigError
  • ContractError
• deisa.ray.head_node module
• deisa.ray.ray_patch module
• deisa.ray.scheduling_actor module
  • NodeActorBase
    • NodeActorBase.actor_id
    • NodeActorBase.actor_handle
    • NodeActorBase.head
    • NodeActorBase.partial_arrays
    • NodeActorBase.feedback_non_chunked
    • NodeActorBase.add_chunk()
    • NodeActorBase.delete()
    • NodeActorBase.get()
    • NodeActorBase.preprocessing_callbacks()
    • NodeActorBase.ready()
    • NodeActorBase.register_chunk_meta()
    • NodeActorBase.set()
• deisa.ray.types module
  • ArrayPerTimestep
    • ArrayPerTimestep.chunks_ready_event
    • ArrayPerTimestep.local_chunks
  • ChunkRef
    • ChunkRef.actor_id
    • ChunkRef.array_name
    • ChunkRef.bridge_id
    • ChunkRef.position
    • ChunkRef.timestep
  • DaskArrayData
    • DaskArrayData.name
    • DaskArrayData.f_preprocessing
    • DaskArrayData.fully_defined
    • DaskArrayData.nb_chunks_per_dim
    • DaskArrayData.nb_chunks
    • DaskArrayData.chunks_size
    • DaskArrayData.dtype
    • DaskArrayData.position_to_node_actorID
    • DaskArrayData.position_to_bridgeID
    • DaskArrayData.nb_scheduling_actors
    • DaskArrayData.chunk_refs
    • DaskArrayData.pos_to_ref_by_timestep
    • DaskArrayData.add_chunk_ref()
    • DaskArrayData.get_full_array()
    • DaskArrayData.update_meta()
  • GraphInfo
    • GraphInfo.scheduled_event
    • GraphInfo.refs
  • PartialArray
    • PartialArray.ready_event
    • PartialArray.chunks_contained_meta
    • PartialArray.bid_to_pos
    • PartialArray.per_timestep_arrays
  • ScheduledByOtherActor
    • ScheduledByOtherActor.actor_id
  • WindowArrayDefinition
    • WindowArrayDefinition.name
    • WindowArrayDefinition.preprocess()
    • WindowArrayDefinition.window_size
• deisa.ray.utils module
  • get_head_actor_options()
  • get_head_node_id()
  • get_ready_actor_with_retry()
  • get_system_metadata()
• deisa.ray.window_handler module
  • Deisa
    • Deisa.execute_callbacks()
    • Deisa.register_callback()
    • Deisa.set()
    • Deisa.unregister_callback()

Module contents