From 6fb2412d26d6f2471442ba65f6e1ad007aa54e0a Mon Sep 17 00:00:00 2001 From: Stanislav Novosad Date: Tue, 14 Oct 2025 12:00:17 -0600 Subject: [PATCH] Cleanup some type related warning (#3706) --- skyvern/forge/sdk/db/client.py | 1 - skyvern/forge/sdk/workflow/context_manager.py | 5 +++++ skyvern/forge/sdk/workflow/service.py | 15 +++++++-------- 3 files changed, 12 insertions(+), 9 deletions(-) diff --git a/skyvern/forge/sdk/db/client.py b/skyvern/forge/sdk/db/client.py index 14901c05..9cdff636 100644 --- a/skyvern/forge/sdk/db/client.py +++ b/skyvern/forge/sdk/db/client.py @@ -893,7 +893,6 @@ class AgentDB: token_type: Literal["api", "onepassword_service_account", "azure_client_secret_credential"], ) -> OrganizationAuthToken | AzureOrganizationAuthToken | None: try: - print("lol") async with self.Session() as session: if token := ( await session.scalars( diff --git a/skyvern/forge/sdk/workflow/context_manager.py b/skyvern/forge/sdk/workflow/context_manager.py index 0d273ed4..ac3a5197 100644 --- a/skyvern/forge/sdk/workflow/context_manager.py +++ b/skyvern/forge/sdk/workflow/context_manager.py @@ -70,6 +70,8 @@ class WorkflowRunContext: | BitwardenLoginCredentialParameter | BitwardenCreditCardDataParameter | BitwardenSensitiveInformationParameter + | OnePasswordCredentialParameter + | AzureVaultCredentialParameter | CredentialParameter ], block_outputs: dict[str, Any] | None = None, @@ -1012,6 +1014,9 @@ class WorkflowContextManager: | BitwardenLoginCredentialParameter | BitwardenCreditCardDataParameter | BitwardenSensitiveInformationParameter + | OnePasswordCredentialParameter + | AzureVaultCredentialParameter + | CredentialParameter ], block_outputs: dict[str, Any] | None = None, ) -> WorkflowRunContext: diff --git a/skyvern/forge/sdk/workflow/service.py b/skyvern/forge/sdk/workflow/service.py index 35411009..a761c757 100644 --- a/skyvern/forge/sdk/workflow/service.py +++ b/skyvern/forge/sdk/workflow/service.py @@ -3,7 +3,7 @@ import json import uuid from collections import deque from datetime import UTC, datetime -from typing import Any, Literal +from typing import Any, Literal, cast import httpx import structlog @@ -31,7 +31,6 @@ from skyvern.forge.sdk.core import skyvern_context from skyvern.forge.sdk.core.security import generate_skyvern_webhook_headers from skyvern.forge.sdk.core.skyvern_context import SkyvernContext from skyvern.forge.sdk.db.enums import TaskType -from skyvern.forge.sdk.db.models import AzureVaultCredentialParameterModel from skyvern.forge.sdk.models import Step, StepStatus from skyvern.forge.sdk.schemas.files import FileInfo from skyvern.forge.sdk.schemas.organizations import Organization @@ -1395,7 +1394,7 @@ class WorkflowService: description: str | None = None, bitwarden_collection_id: str | None = None, bitwarden_item_id: str | None = None, - ) -> Parameter: + ) -> BitwardenLoginCredentialParameter: return await app.DATABASE.create_bitwarden_login_credential_parameter( workflow_id=workflow_id, bitwarden_client_id_aws_secret_key=bitwarden_client_id_aws_secret_key, @@ -1447,7 +1446,7 @@ class WorkflowService: password_key: str, totp_secret_key: str | None = None, description: str | None = None, - ) -> AzureVaultCredentialParameterModel: + ) -> AzureVaultCredentialParameter: return await app.DATABASE.create_azure_vault_credential_parameter( workflow_id=workflow_id, key=key, @@ -1469,7 +1468,7 @@ class WorkflowService: bitwarden_identity_fields: list[str], key: str, description: str | None = None, - ) -> Parameter: + ) -> BitwardenSensitiveInformationParameter: return await app.DATABASE.create_bitwarden_sensitive_information_parameter( workflow_id=workflow_id, bitwarden_client_id_aws_secret_key=bitwarden_client_id_aws_secret_key, @@ -1492,7 +1491,7 @@ class WorkflowService: bitwarden_item_id: str, key: str, description: str | None = None, - ) -> Parameter: + ) -> BitwardenCreditCardDataParameter: return await app.DATABASE.create_bitwarden_credit_card_data_parameter( workflow_id=workflow_id, bitwarden_client_id_aws_secret_key=bitwarden_client_id_aws_secret_key, @@ -2326,9 +2325,9 @@ class WorkflowService: @staticmethod async def block_yaml_to_block( block_yaml: BLOCK_YAML_TYPES, - parameters: dict[str, Parameter], + parameters: dict[str, PARAMETER_TYPE], ) -> BlockTypeVar: - output_parameter = parameters[f"{block_yaml.label}_output"] + output_parameter = cast(OutputParameter, parameters[f"{block_yaml.label}_output"]) if block_yaml.block_type == BlockType.TASK: task_block_parameters = ( [parameters[parameter_key] for parameter_key in block_yaml.parameter_keys]