stick_ray

stick_ray

Submodules

• blocking_dict
• eventbus
• namespace
• routed_services
• stateful_worker
• utils

Package Contents

class RoutedServiceHandle(router, sync)

A class representing a handle that can be used to transparently dish out requests to a routed service.

Initialised routed service handle.

Parameters:

• router (ray.actor.ActorHandle) – an actor handle for the router

• sync (bool) – whether to produce a sync handle, or async handle.

__getattr__(item)

routed_service(expiry_period, name=None, worker_actor_options=None, max_concurrent_sessions=10, min_num_workers=0)

Parameters:

• expiry_period (datetime.timedelta) –

• name (Union[str, None]) –

• worker_actor_options (Union[Dict[str, Any], None]) –

• max_concurrent_sessions (int) –

• min_num_workers (int) –

Return type:

Callable[[Type[V]], FProtocol]