deisa.ray package

Submodules

• deisa.ray.bridge module
• deisa.ray.comm module
• 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
  • ArrayPerTimestep
    • ArrayPerTimestep.chunks_ready_event
    • ArrayPerTimestep.local_chunks
  • ChunkRef
  • 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.get_full_array()
    • DaskArrayData.update_meta()
  • DeisaArray
    • DeisaArray.to_hdf5()
    • DeisaArray.to_zarr()
  • GraphInfo
    • GraphInfo.scheduled_event
    • GraphInfo.refs
  • PartialArray
    • PartialArray.ready_event
    • PartialArray.chunks_contained_meta
    • PartialArray.bid_to_pos
    • PartialArray.per_timestep_arrays
  • ScheduledByOtherActor
  • WindowSpec
  • chunk_fname()
  • create_vds()
  • save_chunk()
  • to_hdf5()
• 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