nemo_gym.web.resources_server

Backend-neutral HTTP resource server for stateful web rollouts.

Module Contents

Classes

Name	Description
`WebResourcesServer`	Expose any common-protocol web backend through Gym’s session API.
`_BearerAuthMiddleware`	Check bearer tokens while keeping downstream ASGI handling in the calling task.

Functions

Name	Description
`_error_response`	-

Data

LOG

API

class nemo_gym.web.resources_server.WebResourcesServer()

Bases: SimpleResourcesServer

Expose any common-protocol web backend through Gym’s session API.

_manager

WebSessionManager = PrivateAttr()

_session_control

WebSessionControl = PrivateAttr()

config

WebResourcesServerConfig

nemo_gym.web.resources_server.WebResourcesServer._check_identity_cookie(
    request: fastapi.Request,
    body: nemo_gym.web.api_models.WebSessionIdentity
) -> None

staticmethod

nemo_gym.web.resources_server.WebResourcesServer._session_id(
    request: fastapi.Request
) -> str

staticmethod

nemo_gym.web.resources_server.WebResourcesServer.close_session(
    request: fastapi.Request,
    body: nemo_gym.web.api_models.WebSessionIdentity | None = None
) -> nemo_gym.web.api_models.WebCloseResponse | fastapi.responses.JSONResponse

async

nemo_gym.web.resources_server.WebResourcesServer.evaluate(
    request: fastapi.Request,
    body: nemo_gym.web.api_models.WebEvaluateRequest
) -> nemo_gym.web.api_models.WebEvaluateResponse

async

nemo_gym.web.resources_server.WebResourcesServer.healthz()

async

nemo_gym.web.resources_server.WebResourcesServer.make_session_manager() -> nemo_gym.web.session_manager.WebSessionManager

Create the backend-specific manager used by the common HTTP API.

nemo_gym.web.resources_server.WebResourcesServer.model_post_init(
    _context
) -> None

nemo_gym.web.resources_server.WebResourcesServer.observe(
    request: fastapi.Request
)

async

nemo_gym.web.resources_server.WebResourcesServer.reset_session(
    request: fastapi.Request,
    body: nemo_gym.web.api_models.WebResetRequest
) -> nemo_gym.web.api_models.WebSeedSessionResponse

async

nemo_gym.web.resources_server.WebResourcesServer.seed_session(
    request: fastapi.Request,
    body: nemo_gym.web.api_models.WebSeedSessionRequest
) -> nemo_gym.web.api_models.WebSeedSessionResponse

async

nemo_gym.web.resources_server.WebResourcesServer.session_status(
    request: fastapi.Request
) -> nemo_gym.web.api_models.WebSessionStatusResponse

async

nemo_gym.web.resources_server.WebResourcesServer.setup_webserver() -> fastapi.FastAPI

nemo_gym.web.resources_server.WebResourcesServer.step(
    request: fastapi.Request,
    body: nemo_gym.web.api_models.WebStepRequest
) -> nemo_gym.web.api_models.WebStepResponse

async

nemo_gym.web.resources_server.WebResourcesServer.verify(
    request: fastapi.Request,
    body: nemo_gym.web.api_models.WebVerifyRequest
) -> nemo_gym.web.api_models.WebVerifyResponse

async

Run the colocated benchmark evaluator and always release the browser.

class nemo_gym.web.resources_server._BearerAuthMiddleware(
    app: starlette.types.ASGIApp,
    config: nemo_gym.web.resource_config.WebResourcesServerConfig
)

Check bearer tokens while keeping downstream ASGI handling in the calling task.

nemo_gym.web.resources_server._BearerAuthMiddleware.__call__(
    scope: starlette.types.Scope,
    receive: starlette.types.Receive,
    send: starlette.types.Send
) -> None

async

nemo_gym.web.resources_server._error_response(
    status_code: int,
    detail: str,
    error_kind: str,
    retryable: bool
) -> fastapi.responses.JSONResponse

nemo_gym.web.resources_server.LOG = logging.getLogger('nemo_gym.web.resources_server')