deisa.ray package

Submodules

• deisa.ray.bridge module
  • Bridge
    • Bridge.node_id
    • Bridge.close()
    • Bridge.get()
    • Bridge.send()
• deisa.ray.comm module
  • Comm
    • Comm.barrier()
    • Comm.rank
    • Comm.world_size
  • MPICommAdapter
    • MPICommAdapter.barrier()
  • NoOpComm
    • NoOpComm.barrier()
  • TorchDistComm
    • TorchDistComm.barrier()
  • init_gloo_comm()
• 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.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.ready()
    • NodeActorBase.register_chunk_meta()
    • NodeActorBase.set()
• deisa.ray.types module
  • ActorID
  • ArrayPerTimestep
    • ArrayPerTimestep.chunks_ready_event
    • ArrayPerTimestep.local_chunks
  • ChunkRef
    • ChunkRef.actorid
    • ChunkRef.array_name
    • ChunkRef.bridge_id
    • ChunkRef.ref
    • ChunkRef.timestep
  • DaskArrayData
    • DaskArrayData.name
    • 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.chunk_refs
    • DaskArrayData.chunks_size
    • DaskArrayData.dtype
    • DaskArrayData.fully_defined
    • DaskArrayData.get_full_array()
    • DaskArrayData.nb_chunks
    • DaskArrayData.nb_chunks_per_dim
    • DaskArrayData.nb_scheduling_actors
    • DaskArrayData.pos_to_ref_by_timestep
    • DaskArrayData.position_to_bridgeID
    • DaskArrayData.position_to_node_actorID
    • DaskArrayData.update_meta()
  • DeisaArray
    • DeisaArray.dask
    • DeisaArray.t
  • DoubleRef
  • GraphInfo
    • GraphInfo.scheduled_event
    • GraphInfo.refs
    • GraphInfo.refs
  • GraphKey
  • GraphValue
  • PartialArray
    • PartialArray.ready_event
    • PartialArray.chunks_contained_meta
    • PartialArray.bid_to_pos
    • PartialArray.per_timestep_arrays
    • PartialArray.bid_to_pos
    • PartialArray.chunks_contained_meta
    • PartialArray.per_timestep_arrays
  • ScheduledByOtherActor
    • ScheduledByOtherActor.actor_id
  • WindowSpec
    • WindowSpec.name
    • WindowSpec.window_size
• deisa.ray.utils module
  • get_head_actor_options()
  • get_head_node_id()
  • get_node_actor_options()
  • get_ready_actor_with_retry()
  • get_system_metadata()
  • log()
• deisa.ray.validate module
• deisa.ray.window_handler module
  • Deisa
    • Deisa.callback()
    • Deisa.determine_callback_args()
    • Deisa.execute_callbacks()
    • Deisa.generate_queue_per_array()
    • Deisa.register_callback()
    • Deisa.set()
    • Deisa.should_call()
    • Deisa.unregister_callback()

Module contents