Function create_actor_fn

python/ray/data/tests/test_actor_pool_map_operator.py:914–919

(
        labels: Dict[str, Any],
        logical_actor_id: str = "Actor1",
    )

    logger_name = "ray.data._internal.execution.operators.actor_pool_map_operator"

    def create_actor_fn(
        labels: Dict[str, Any],
        logical_actor_id: str = "Actor1",
    ) -> Tuple[ActorHandle, ObjectRef[Any], ExecutionResources]:
        actor = PoolWorker.options(_labels=labels).remote("node1")
        return actor, actor.get_location.remote(), ExecutionResources(cpu=1)

    config = AutoscalingActorConfig(
        min_size=1,