use model_name instead of name (#2557)
This commit is contained in:
@@ -272,22 +272,22 @@ class Settings(BaseSettings):
|
|||||||
|
|
||||||
if self.is_cloud_environment():
|
if self.is_cloud_environment():
|
||||||
return {
|
return {
|
||||||
"Gemini 2.5": "GEMINI_2.5_PRO_PREVIEW",
|
"gemini-2.5-pro-preview-05-06": "VERTEX_GEMINI_2.5_PRO_PREVIEW",
|
||||||
"Gemini 2.5 Flash": "VERTEX_GEMINI_2.5_FLASH_PREVIEW_05_20",
|
"gemini-2.5-flash-preview-05-20": "VERTEX_GEMINI_2.5_FLASH_PREVIEW_05_20",
|
||||||
"GPT 4.1": "OPENAI_GPT4_1",
|
"azure/gpt-4.1": "AZURE_OPENAI_GPT4_1",
|
||||||
"GPT o3-mini": "OPENAI_O3_MINI",
|
"azure/o3-mini": "AZURE_OPENAI_O3_MINI",
|
||||||
"bedrock/us.anthropic.claude-opus-4-20250514-v1:0": "BEDROCK_ANTHROPIC_CLAUDE4_OPUS_INFERENCE_PROFILE",
|
"us.anthropic.claude-opus-4-20250514-v1:0": "BEDROCK_ANTHROPIC_CLAUDE4_OPUS_INFERENCE_PROFILE",
|
||||||
"bedrock/us.anthropic.claude-sonnet-4-20250514-v1:0": "BEDROCK_ANTHROPIC_CLAUDE4_SONNET_INFERENCE_PROFILE",
|
"us.anthropic.claude-sonnet-4-20250514-v1:0": "BEDROCK_ANTHROPIC_CLAUDE4_SONNET_INFERENCE_PROFILE",
|
||||||
}
|
}
|
||||||
else:
|
else:
|
||||||
# TODO: apparently the list for OSS is to be much larger
|
# TODO: apparently the list for OSS is to be much larger
|
||||||
return {
|
return {
|
||||||
"Gemini 2.5": "GEMINI_2.5_PRO_PREVIEW",
|
"gemini-2.5-pro-preview-05-06": "VERTEX_GEMINI_2.5_PRO_PREVIEW",
|
||||||
"Gemini 2.5 Flash": "VERTEX_GEMINI_2.5_FLASH_PREVIEW_05_20",
|
"gemini-2.5-flash-preview-05-20": "VERTEX_GEMINI_2.5_FLASH_PREVIEW_05_20",
|
||||||
"GPT 4.1": "OPENAI_GPT4_1",
|
"azure/gpt-4.1": "AZURE_OPENAI_GPT4_1",
|
||||||
"GPT o3-mini": "OPENAI_O3_MINI",
|
"azure/o3-mini": "AZURE_OPENAI_O3_MINI",
|
||||||
"bedrock/us.anthropic.claude-opus-4-20250514-v1:0": "BEDROCK_ANTHROPIC_CLAUDE4_OPUS_INFERENCE_PROFILE",
|
"us.anthropic.claude-opus-4-20250514-v1:0": "BEDROCK_ANTHROPIC_CLAUDE4_OPUS_INFERENCE_PROFILE",
|
||||||
"bedrock/us.anthropic.claude-sonnet-4-20250514-v1:0": "BEDROCK_ANTHROPIC_CLAUDE4_SONNET_INFERENCE_PROFILE",
|
"us.anthropic.claude-sonnet-4-20250514-v1:0": "BEDROCK_ANTHROPIC_CLAUDE4_SONNET_INFERENCE_PROFILE",
|
||||||
}
|
}
|
||||||
|
|
||||||
def is_cloud_environment(self) -> bool:
|
def is_cloud_environment(self) -> bool:
|
||||||
|
|||||||
@@ -867,12 +867,13 @@ class ForgeAgent:
|
|||||||
else:
|
else:
|
||||||
if engine in CUA_ENGINES:
|
if engine in CUA_ENGINES:
|
||||||
self.async_operation_pool.run_operation(task.task_id, AgentPhase.llm)
|
self.async_operation_pool.run_operation(task.task_id, AgentPhase.llm)
|
||||||
|
|
||||||
json_response = await app.LLM_API_HANDLER(
|
json_response = await app.LLM_API_HANDLER(
|
||||||
prompt=extract_action_prompt,
|
prompt=extract_action_prompt,
|
||||||
prompt_name="extract-actions",
|
prompt_name="extract-actions",
|
||||||
step=step,
|
step=step,
|
||||||
screenshots=scraped_page.screenshots,
|
screenshots=scraped_page.screenshots,
|
||||||
llm_key_override=llm_caller.llm_key if llm_caller else None,
|
llm_key_override=task.llm_key,
|
||||||
)
|
)
|
||||||
try:
|
try:
|
||||||
json_response = await self.handle_potential_verification_code(
|
json_response = await self.handle_potential_verification_code(
|
||||||
|
|||||||
@@ -57,7 +57,7 @@ class TaskV2(BaseModel):
|
|||||||
"""
|
"""
|
||||||
|
|
||||||
if self.model:
|
if self.model:
|
||||||
model_name = self.model.get("name")
|
model_name = self.model.get("model_name")
|
||||||
if model_name:
|
if model_name:
|
||||||
mapping = settings.get_model_name_to_llm_key()
|
mapping = settings.get_model_name_to_llm_key()
|
||||||
llm_key = mapping.get(model_name)
|
llm_key = mapping.get(model_name)
|
||||||
|
|||||||
@@ -248,7 +248,7 @@ class Task(TaskBase):
|
|||||||
Otherwise return `None`.
|
Otherwise return `None`.
|
||||||
"""
|
"""
|
||||||
if self.model:
|
if self.model:
|
||||||
model_name = self.model.get("name")
|
model_name = self.model.get("model_name")
|
||||||
if model_name:
|
if model_name:
|
||||||
mapping = settings.get_model_name_to_llm_key()
|
mapping = settings.get_model_name_to_llm_key()
|
||||||
return mapping.get(model_name)
|
return mapping.get(model_name)
|
||||||
|
|||||||
@@ -5,11 +5,10 @@ from typing import Any, List
|
|||||||
from pydantic import BaseModel, field_validator
|
from pydantic import BaseModel, field_validator
|
||||||
from typing_extensions import deprecated
|
from typing_extensions import deprecated
|
||||||
|
|
||||||
from skyvern.config import settings
|
|
||||||
from skyvern.forge.sdk.schemas.files import FileInfo
|
from skyvern.forge.sdk.schemas.files import FileInfo
|
||||||
from skyvern.forge.sdk.schemas.task_v2 import TaskV2
|
from skyvern.forge.sdk.schemas.task_v2 import TaskV2
|
||||||
from skyvern.forge.sdk.workflow.exceptions import WorkflowDefinitionHasDuplicateBlockLabels
|
from skyvern.forge.sdk.workflow.exceptions import WorkflowDefinitionHasDuplicateBlockLabels
|
||||||
from skyvern.forge.sdk.workflow.models.block import Block, BlockTypeVar
|
from skyvern.forge.sdk.workflow.models.block import BlockTypeVar
|
||||||
from skyvern.forge.sdk.workflow.models.parameter import PARAMETER_TYPE
|
from skyvern.forge.sdk.workflow.models.parameter import PARAMETER_TYPE
|
||||||
from skyvern.schemas.runs import ProxyLocation
|
from skyvern.schemas.runs import ProxyLocation
|
||||||
from skyvern.utils.url_validators import validate_url
|
from skyvern.utils.url_validators import validate_url
|
||||||
@@ -82,34 +81,6 @@ class Workflow(BaseModel):
|
|||||||
modified_at: datetime
|
modified_at: datetime
|
||||||
deleted_at: datetime | None = None
|
deleted_at: datetime | None = None
|
||||||
|
|
||||||
def determine_llm_key(self, *, block: Block | None = None) -> str | None:
|
|
||||||
"""
|
|
||||||
Determine the LLM key override to use for a block, if it has one.
|
|
||||||
|
|
||||||
It has one if:
|
|
||||||
- it defines one, or
|
|
||||||
- the workflow it is a part of (if applicable) defines one
|
|
||||||
"""
|
|
||||||
|
|
||||||
mapping = settings.get_model_name_to_llm_key()
|
|
||||||
|
|
||||||
if block:
|
|
||||||
model_name = (block.model or {}).get("name")
|
|
||||||
|
|
||||||
if model_name:
|
|
||||||
llm_key = mapping.get(model_name)
|
|
||||||
if llm_key:
|
|
||||||
return llm_key
|
|
||||||
|
|
||||||
workflow_model_name = (self.model or {}).get("name")
|
|
||||||
|
|
||||||
if workflow_model_name:
|
|
||||||
llm_key = mapping.get(workflow_model_name)
|
|
||||||
if llm_key:
|
|
||||||
return llm_key
|
|
||||||
|
|
||||||
return None
|
|
||||||
|
|
||||||
|
|
||||||
class WorkflowRunStatus(StrEnum):
|
class WorkflowRunStatus(StrEnum):
|
||||||
created = "created"
|
created = "created"
|
||||||
|
|||||||
Reference in New Issue
Block a user