@@ -213,7 +213,7 @@ def test_execute_workflow_function_sync(self, workflow_engine):
213213 input_data = "test-input"
214214
215215 # Execute the workflow function
216- result = workflow_engine ._execute_workflow_function_sync (workflow_engine ._workflow_func , input_data )
216+ result = workflow_engine ._execute_workflow_function_once (workflow_engine ._workflow_func , input_data )
217217
218218 # Verify the result
219219 assert result == "processed: test-input"
@@ -226,7 +226,7 @@ async def async_workflow_func(input_data):
226226 input_data = "test-input"
227227
228228 # Execute the async workflow function
229- result = workflow_engine ._execute_workflow_function_sync (async_workflow_func , input_data )
229+ result = workflow_engine ._execute_workflow_function_once (async_workflow_func , input_data )
230230
231231 # Verify the result
232232 assert result == "async-processed: test-input"
@@ -237,7 +237,7 @@ def test_execute_workflow_function_none(self, workflow_engine):
237237
238238 # Execute with None workflow function - should raise TypeError
239239 with pytest .raises (TypeError , match = "'NoneType' object is not callable" ):
240- workflow_engine ._execute_workflow_function_sync (None , input_data )
240+ workflow_engine ._execute_workflow_function_once (None , input_data )
241241
242242 def test_workflow_engine_initialization (self , workflow_engine , workflow_info , mock_client , mock_workflow_func ):
243243 """Test WorkflowEngine initialization."""
0 commit comments