Skip to content

Commit c6f1165

Browse files
committed
minor rename
Signed-off-by: Tim Li <[email protected]>
1 parent a8432b6 commit c6f1165

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

cadence/_internal/workflow/workflow_engine.py

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -275,7 +275,7 @@ async def _execute_workflow_function(self, decision_task: PollForDecisionTaskRes
275275
workflow_input = await self._extract_workflow_input(decision_task)
276276

277277
# Execute workflow function
278-
result = self._execute_workflow_function_sync(workflow_func, workflow_input)
278+
result = self._execute_workflow_function_once(workflow_func, workflow_input)
279279

280280
# Check if workflow is complete
281281
if result is not None:
@@ -337,14 +337,14 @@ async def _extract_workflow_input(self, decision_task: PollForDecisionTaskRespon
337337
logger.warning("No WorkflowExecutionStarted event found in history")
338338
return None
339339

340-
def _execute_workflow_function_sync(self, workflow_func: Callable, workflow_input: Any) -> Any:
340+
def _execute_workflow_function_once(self, workflow_func: Callable, workflow_input: Any) -> Any:
341341
"""
342-
Execute the workflow function synchronously.
343-
342+
Execute the workflow function once (not during replay).
343+
344344
Args:
345345
workflow_func: The workflow function to execute
346346
workflow_input: The input data for the workflow function
347-
347+
348348
Returns:
349349
The result of the workflow function execution
350350
"""

0 commit comments

Comments
 (0)