2020
2121# region imports
2222import asyncio
23+ from pydantic import BaseModel
2324import time
2425# endregion imports
2526
@@ -55,7 +56,7 @@ def _init_sdks(self):
5556 def execute_workflow_and_wait (
5657 self ,
5758 workflow_identifier : str ,
58- input : OptionalNullable [Dict [str , Any ]] = UNSET ,
59+ input : OptionalNullable [Dict [str , Any ] | BaseModel ] = UNSET ,
5960 execution_id : OptionalNullable [str ] = UNSET ,
6061 deployment_name : OptionalNullable [str ] = UNSET ,
6162 custom_tracing_attributes : OptionalNullable [Dict [str , str ]] = UNSET ,
@@ -68,7 +69,7 @@ def execute_workflow_and_wait(
6869
6970 Args:
7071 workflow_identifier: The workflow name or ID.
71- input: Input parameters for the workflow
72+ input: The input to the workflow. This should be a dictionary or a BaseModel that matches the workflow's input schema.
7273 execution_id: Optional custom execution ID
7374 deployment_name: Name of the deployment to route this execution to
7475 custom_tracing_attributes: Custom tracing attributes
@@ -152,7 +153,7 @@ def wait_for_workflow_completion(
152153 async def execute_workflow_and_wait_async (
153154 self ,
154155 workflow_identifier : str ,
155- input : OptionalNullable [Dict [str , Any ]] = UNSET ,
156+ input : OptionalNullable [Dict [str , Any ] | BaseModel ] = UNSET ,
156157 execution_id : OptionalNullable [str ] = UNSET ,
157158 deployment_name : OptionalNullable [str ] = UNSET ,
158159 custom_tracing_attributes : OptionalNullable [Dict [str , str ]] = UNSET ,
@@ -165,7 +166,7 @@ async def execute_workflow_and_wait_async(
165166
166167 Args:
167168 workflow_identifier: The workflow name or ID.
168- input: Input parameters for the workflow
169+ input: The input to the workflow. This should be a dictionary or a BaseModel that matches the workflow's input schema.
169170 execution_id: Optional custom execution ID
170171 deployment_name: Name of the deployment to route this execution to
171172 custom_tracing_attributes: Custom tracing attributes
0 commit comments