Skip to content

D
dify
Commit db299a87 authored by takatost's avatar takatost
Browse files
Options

add sequence_number for workflow_started event

parent 737d0436
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 0 deletions
api/core/app/apps/advanced_chat/generate_task_pipeline.py
View file @ db299a87
...@@ -226,6 +226,7 @@ class AdvancedChatAppGenerateTaskPipeline(WorkflowBasedGenerateTaskPipeline): ...@@ -226,6 +226,7 @@ class AdvancedChatAppGenerateTaskPipeline(WorkflowBasedGenerateTaskPipeline):
'data': { 'data': {
'id': workflow_run.id, 'id': workflow_run.id,
'workflow_id': workflow_run.workflow_id, 'workflow_id': workflow_run.workflow_id,
'sequence_number': workflow_run.sequence_number,
'created_at': int(workflow_run.created_at.timestamp()) 'created_at': int(workflow_run.created_at.timestamp())
} }
} }
......
api/core/app/apps/workflow/generate_task_pipeline.py
View file @ db299a87
...@@ -195,6 +195,7 @@ class WorkflowAppGenerateTaskPipeline(WorkflowBasedGenerateTaskPipeline): ...@@ -195,6 +195,7 @@ class WorkflowAppGenerateTaskPipeline(WorkflowBasedGenerateTaskPipeline):
'data': { 'data': {
'id': workflow_run.id, 'id': workflow_run.id,
'workflow_id': workflow_run.workflow_id, 'workflow_id': workflow_run.workflow_id,
'sequence_number': workflow_run.sequence_number,
'created_at': int(workflow_run.created_at.timestamp()) 'created_at': int(workflow_run.created_at.timestamp())
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment