diff --git a/keep/api/core/db.py b/keep/api/core/db.py index 6449a8b24..ba2a32312 100644 --- a/keep/api/core/db.py +++ b/keep/api/core/db.py @@ -688,7 +688,15 @@ def finish_workflow_execution(tenant_id, workflow_id, execution_id, status, erro def get_workflow_executions(tenant_id, workflow_id, limit=50): with Session(engine) as session: workflow_executions = session.exec( - select(WorkflowExecution) + select( + WorkflowExecution.id, + WorkflowExecution.workflow_id, + WorkflowExecution.started, + WorkflowExecution.status, + WorkflowExecution.triggered_by, + WorkflowExecution.execution_time, + WorkflowExecution.error, + ) .where(WorkflowExecution.tenant_id == tenant_id) .where(WorkflowExecution.workflow_id == workflow_id) .where( diff --git a/keep/api/routes/workflows.py b/keep/api/routes/workflows.py index a53743700..04dff9638 100644 --- a/keep/api/routes/workflows.py +++ b/keep/api/routes/workflows.py @@ -394,7 +394,6 @@ def get_workflow_by_id( "triggered_by": workflow_execution.triggered_by, "error": workflow_execution.error, "execution_time": workflow_execution.execution_time, - "results": workflow_execution.results, } workflow_executions_dtos.append(workflow_execution_dto)