@@ -57,9 +57,6 @@ def execute_workflow_and_wait(
5757 self ,
5858 workflow_identifier : str ,
5959 input : OptionalNullable [Dict [str , Any ] | BaseModel ] = UNSET ,
60- encoded_input : OptionalNullable [
61- Union [models .NetworkEncodedInput , models .NetworkEncodedInputTypedDict ]
62- ] = UNSET ,
6360 execution_id : OptionalNullable [str ] = UNSET ,
6461 deployment_name : OptionalNullable [str ] = UNSET ,
6562 custom_tracing_attributes : OptionalNullable [Dict [str , str ]] = UNSET ,
@@ -78,7 +75,6 @@ def execute_workflow_and_wait(
7875 Args:
7976 workflow_identifier: The workflow name or ID.
8077 input: The input to the workflow. This should be a dictionary or a BaseModel that matches the workflow's input schema.
81- encoded_input: Encoded input to the workflow, used when payload encoding is enabled.
8278 execution_id: Optional custom execution ID
8379 deployment_name: Name of the deployment to route this execution to
8480 custom_tracing_attributes: Custom tracing attributes
@@ -104,7 +100,6 @@ def execute_workflow_and_wait(
104100 response = self .execute_workflow (
105101 workflow_identifier = workflow_identifier ,
106102 input = input ,
107- encoded_input = encoded_input ,
108103 execution_id = execution_id ,
109104 wait_for_result = True ,
110105 timeout_seconds = timeout_seconds ,
@@ -121,7 +116,6 @@ def execute_workflow_and_wait(
121116 execution = self .execute_workflow (
122117 workflow_identifier = workflow_identifier ,
123118 input = input ,
124- encoded_input = encoded_input ,
125119 execution_id = execution_id ,
126120 custom_tracing_attributes = custom_tracing_attributes ,
127121 task_queue = task_queue ,
@@ -180,9 +174,6 @@ async def execute_workflow_and_wait_async(
180174 self ,
181175 workflow_identifier : str ,
182176 input : OptionalNullable [Dict [str , Any ] | BaseModel ] = UNSET ,
183- encoded_input : OptionalNullable [
184- Union [models .NetworkEncodedInput , models .NetworkEncodedInputTypedDict ]
185- ] = UNSET ,
186177 execution_id : OptionalNullable [str ] = UNSET ,
187178 deployment_name : OptionalNullable [str ] = UNSET ,
188179 custom_tracing_attributes : OptionalNullable [Dict [str , str ]] = UNSET ,
@@ -201,7 +192,6 @@ async def execute_workflow_and_wait_async(
201192 Args:
202193 workflow_identifier: The workflow name or ID.
203194 input: The input to the workflow. This should be a dictionary or a BaseModel that matches the workflow's input schema.
204- encoded_input: Encoded input to the workflow, used when payload encoding is enabled.
205195 execution_id: Optional custom execution ID
206196 deployment_name: Name of the deployment to route this execution to
207197 custom_tracing_attributes: Custom tracing attributes
@@ -227,7 +217,6 @@ async def execute_workflow_and_wait_async(
227217 response = await self .execute_workflow_async (
228218 workflow_identifier = workflow_identifier ,
229219 input = input ,
230- encoded_input = encoded_input ,
231220 execution_id = execution_id ,
232221 wait_for_result = True ,
233222 timeout_seconds = timeout_seconds ,
@@ -245,7 +234,6 @@ async def execute_workflow_and_wait_async(
245234 execution = await self .execute_workflow_async (
246235 workflow_identifier = workflow_identifier ,
247236 input = input ,
248- encoded_input = encoded_input ,
249237 execution_id = execution_id ,
250238 custom_tracing_attributes = custom_tracing_attributes ,
251239 task_queue = task_queue ,
0 commit comments