SKYVERN_BROWSER_VNC_PORT (#2702)
This commit is contained in:
@@ -265,6 +265,12 @@ class Settings(BaseSettings):
|
|||||||
SKYVERN_BASE_URL: str = "https://api.skyvern.com"
|
SKYVERN_BASE_URL: str = "https://api.skyvern.com"
|
||||||
SKYVERN_API_KEY: str = "PLACEHOLDER"
|
SKYVERN_API_KEY: str = "PLACEHOLDER"
|
||||||
|
|
||||||
|
SKYVERN_BROWSER_VNC_PORT: int = 6080
|
||||||
|
"""
|
||||||
|
The websockified port on which the VNC server of a persistent browser is
|
||||||
|
listening.
|
||||||
|
"""
|
||||||
|
|
||||||
def get_model_name_to_llm_key(self) -> dict[str, dict[str, str]]:
|
def get_model_name_to_llm_key(self) -> dict[str, dict[str, str]]:
|
||||||
"""
|
"""
|
||||||
Keys are model names available to blocks in the frontend. These map to key names
|
Keys are model names available to blocks in the frontend. These map to key names
|
||||||
|
|||||||
@@ -5,12 +5,12 @@ from enum import IntEnum
|
|||||||
|
|
||||||
import structlog
|
import structlog
|
||||||
import websockets
|
import websockets
|
||||||
from cloud.config import settings
|
|
||||||
from fastapi import WebSocket, WebSocketDisconnect
|
from fastapi import WebSocket, WebSocketDisconnect
|
||||||
from starlette.websockets import WebSocketState
|
from starlette.websockets import WebSocketState
|
||||||
from websockets import Data
|
from websockets import Data
|
||||||
from websockets.exceptions import ConnectionClosedError, ConnectionClosedOK
|
from websockets.exceptions import ConnectionClosedError, ConnectionClosedOK
|
||||||
|
|
||||||
|
from skyvern.config import settings
|
||||||
from skyvern.forge import app
|
from skyvern.forge import app
|
||||||
from skyvern.forge.sdk.routes.routers import legacy_base_router
|
from skyvern.forge.sdk.routes.routers import legacy_base_router
|
||||||
from skyvern.forge.sdk.schemas.persistent_browser_sessions import AddressablePersistentBrowserSession
|
from skyvern.forge.sdk.schemas.persistent_browser_sessions import AddressablePersistentBrowserSession
|
||||||
@@ -184,9 +184,8 @@ async def get_streaming_for_task(
|
|||||||
streaming = Streaming(
|
streaming = Streaming(
|
||||||
interactor="user",
|
interactor="user",
|
||||||
organization_id=organization_id,
|
organization_id=organization_id,
|
||||||
vnc_port=settings.PERSISTENT_BROWSER_VNC_PORT,
|
vnc_port=settings.SKYVERN_BROWSER_VNC_PORT,
|
||||||
websocket=websocket,
|
websocket=websocket,
|
||||||
# --
|
|
||||||
browser_session=browser_session,
|
browser_session=browser_session,
|
||||||
task=task,
|
task=task,
|
||||||
)
|
)
|
||||||
@@ -230,8 +229,7 @@ async def get_streaming_for_workflow_run(
|
|||||||
streaming = Streaming(
|
streaming = Streaming(
|
||||||
interactor="user",
|
interactor="user",
|
||||||
organization_id=organization_id,
|
organization_id=organization_id,
|
||||||
vnc_port=settings.PERSISTENT_BROWSER_VNC_PORT,
|
vnc_port=settings.SKYVERN_BROWSER_VNC_PORT,
|
||||||
# --
|
|
||||||
browser_session=browser_session,
|
browser_session=browser_session,
|
||||||
workflow_run=workflow_run,
|
workflow_run=workflow_run,
|
||||||
websocket=websocket,
|
websocket=websocket,
|
||||||
|
|||||||
Reference in New Issue
Block a user