d4a5d09dab446fd9c962c80c87bc7a29f3d8b5cd,python/ray/serve/http_proxy.py,HTTPProxy,__call__,#HTTPProxy#Any#Any#Any#,105

Before Change

        )

        retries = 0
        while retries <= MAX_ACTOR_DEAD_RETRIES:
            try:
                result = await self.router_handle.enqueue_request.remote(
                    request_metadata, scope, http_body_bytes)
                if not isinstance(result, ray.exceptions.RayActorError):
                    await Response(result).send(scope, receive, send)
                    break
                logger.warning("Got RayActorError: {}".format(str(result)))
                await asyncio.sleep(0.1)
            except Exception as e:
                error_message = "Internal Error. Traceback: {}.".format(e)
                await error_sender(error_message, 500)
                break
        else:
            logger.debug("Maximum actor death retries exceeded")
            await error_sender(
                "Internal Error. Maximum actor death retries exceeded", 500)


@ray.remote
class HTTPProxyActor:
    async def __init__(self, host, port, instance_name=None):
        serve.init(name=instance_name)

After Change

        result = await self.router.enqueue_request(request_metadata, scope,
                                                   http_body_bytes)

        if isinstance(result, RayTaskError):
            error_message = "Task Error. Traceback: {}.".format(result)
            await error_sender(error_message, 500)
        else:
            await Response(result).send(scope, receive, send)


@ray.remote
class HTTPProxyActor:
    async def __init__(self, host, port, instance_name=None):
        serve.init(name=instance_name)

Instances