beamds.beam.distributed package#

Submodules#

beamds.beam.distributed.async_client module#

beamds.beam.distributed.async_server module#

beamds.beam.distributed.celery_dispatcher module#

class beamds.beam.distributed.celery_dispatcher.CeleryAsyncResult(obj)[source]#

Bases: MetaAsyncResult

property args#
classmethod from_str(value, app=None)[source]#
property hex#
property is_ready#
property is_success#
property kwargs#
property state#
property value#
wait(timeout=None)[source]#
class beamds.beam.distributed.celery_dispatcher.CeleryDispatcher(*args, _store_init_path=None, _save_init_args=True, **kwargs)[source]#

Bases: MetaDispatcher

property broker[source]#
dispatch(attribute, *args, **kwargs)[source]#
getattr(item)[source]#
metadata(task_id, *args, **kwargs)[source]#
poll(task_id, timeout=0)[source]#

beamds.beam.distributed.celery_worker module#

class beamds.beam.distributed.celery_worker.CeleryWorker(*args, _store_init_path=None, _save_init_args=True, **kwargs)[source]#

Bases: Processor

property broker[source]#
property routes#
run(*routes)[source]#
start_worker()[source]#
property type[source]#
class beamds.beam.distributed.celery_worker.Task(req_id: str, args: Tuple = (), kwargs: Dict = <factory>, done: bool = False, in_progress: bool = False, result: Any = None, success: bool = False, exception: Exception = None, traceback: str = None, start_time: float = None, end_time: float = None)[source]#

Bases: object

args: Tuple = ()#
done: bool = False#
end_time: float = None#
exception: Exception = None#
in_progress: bool = False#
kwargs: Dict#
req_id: str#
result: Any = None#
start_time: float = None#
success: bool = False#
traceback: str = None#

beamds.beam.distributed.ray_dispatcher module#

beamds.beam.distributed.resource module#

beamds.beam.distributed.thread_dispatcher module#

beamds.beam.distributed.utils module#

beamds.beam.distributed.utils.get_backend_url(backend=None, backend_username=None, backend_password=None, backend_port=None, backend_scheme=None, backend_host=None)[source]#
beamds.beam.distributed.utils.get_broker_url(broker=None, broker_username=None, broker_password=None, broker_port=None, broker_scheme=None, broker_host=None)[source]#

Module contents#