opensource
/
dify
mirror of https://github.com/langgenius/dify.git
2
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix: log order wrong

This commit is contained in:
Novice Lee 2024-12-23 13:56:07 +08:00
parent fc15b95b81
commit 6802329055
3 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
api/core/app/apps/workflow_app_runner.py
View File

@ -211,7 +211,7 @@ class WorkflowBasedAppRunner(AppRunner):
parent_parallel_id=event.parent_parallel_id,
parent_parallel_start_node_id=event.parent_parallel_start_node_id,
start_at=event.start_at,
node_run_index=event.node_run_index,
node_run_index=event.route_node_state.index,
predecessor_node_id=event.predecessor_node_id,
in_iteration_id=event.in_iteration_id,
parallel_mode_run_id=event.parallel_mode_run_id,

1
api/core/workflow/graph_engine/entities/event.py
View File

@ -101,7 +101,6 @@ class NodeRunRetryEvent(NodeRunStartedEvent):
error: str = Field(..., description="error")
retry_index: int = Field(..., description="which retry attempt is about to be performed")
start_at: datetime = Field(..., description="retry start time")
node_run_index: int = Field(..., description="retry run index")
###########################################

2
api/core/workflow/graph_engine/graph_engine.py
View File

@ -641,7 +641,6 @@ class GraphEngine:
run_result.status = WorkflowNodeExecutionStatus.SUCCEEDED
if node_instance.should_retry and retries < max_retries:
retries += 1
self.graph_runtime_state.node_run_steps += 1
route_node_state.node_run_result = run_result
yield NodeRunRetryEvent(
id=node_instance.id,
@ -657,7 +656,6 @@ class GraphEngine:
error=run_result.error,
retry_index=retries,
start_at=retry_start_at,
node_run_index=self.graph_runtime_state.node_run_steps,
)
time.sleep(retry_interval)
continue