diff --git a/api/core/app/entities/task_entities.py b/api/core/app/entities/task_entities.py index 29ea7bc935..5de8793cfb 100644 --- a/api/core/app/entities/task_entities.py +++ b/api/core/app/entities/task_entities.py @@ -179,6 +179,7 @@ class WorkflowStartStreamResponse(StreamResponse): id: str workflow_id: str sequence_number: int + inputs: dict created_at: int event: StreamEvent = StreamEvent.WORKFLOW_STARTED diff --git a/api/core/app/task_pipeline/workflow_cycle_manage.py b/api/core/app/task_pipeline/workflow_cycle_manage.py index 8c532d4a5d..42ea3ca780 100644 --- a/api/core/app/task_pipeline/workflow_cycle_manage.py +++ b/api/core/app/task_pipeline/workflow_cycle_manage.py @@ -267,6 +267,8 @@ class WorkflowCycleManage: :param workflow_run: workflow run :return: """ + inputs = {variable: value for variable, value in workflow_run.inputs_dict.items() + if variable != 'sys.conversation'} return WorkflowStartStreamResponse( task_id=task_id, workflow_run_id=workflow_run.id, @@ -274,6 +276,7 @@ class WorkflowCycleManage: id=workflow_run.id, workflow_id=workflow_run.workflow_id, sequence_number=workflow_run.sequence_number, + inputs=inputs, created_at=int(workflow_run.created_at.timestamp()) ) )