filter out workflow status when listing queue tasks

maxdml · maxdml · commit 057a409f7d54 · 2025-08-20T10:11:42.000-07:00
diff --git a/dbos/admin_server.go b/dbos/admin_server.go
@@ -372,7 +372,10 @@ func newAdminServer(ctx *dbosContext, port int) *adminServer {
 			}
 		}
 
-		workflows, err := ListWorkflows(ctx, req.toListWorkflowsOptions()...)
+		req.Status = "" // We are not expecting a filter here but clear just in case
+		filters := req.toListWorkflowsOptions()
+		filters = append(filters, WithStatus([]WorkflowStatusType{WorkflowStatusEnqueued, WorkflowStatusPending}))
+		workflows, err := ListWorkflows(ctx, filters...)
 		if err != nil {
 			ctx.logger.Error("Failed to list queued workflows", "error", err)
 			http.Error(w, fmt.Sprintf("Failed to list queued workflows: %v", err), http.StatusInternalServerError)

Original file line number	Diff line number	Diff line change
`@@ -372,7 +372,10 @@ func newAdminServer(ctx dbosContext, port int) adminServer {`
`372`	`372`	`}`
`373`	`373`	`}`
`374`	`374`
`375`		`- workflows, err := ListWorkflows(ctx, req.toListWorkflowsOptions()...)`
	`375`	`+ req.Status = "" // We are not expecting a filter here but clear just in case`
	`376`	`+ filters := req.toListWorkflowsOptions()`
	`377`	`+ filters = append(filters, WithStatus([]WorkflowStatusType{WorkflowStatusEnqueued, WorkflowStatusPending}))`
	`378`	`+ workflows, err := ListWorkflows(ctx, filters...)`
`376`	`379`	`if err != nil {`
`377`	`380`	`ctx.logger.Error("Failed to list queued workflows", "error", err)`
`378`	`381`	`http.Error(w, fmt.Sprintf("Failed to list queued workflows: %v", err), http.StatusInternalServerError)`