Skip to content

Commit 32a491e

Browse files
committed
same for queues
1 parent 7ac5b5e commit 32a491e

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

dbos/conductor.go

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -640,8 +640,7 @@ func (c *Conductor) handleListQueuedWorkflowsRequest(data []byte, requestID stri
640640
var opts []ListWorkflowsOption
641641
opts = append(opts, WithLoadInput(req.Body.LoadInput))
642642
opts = append(opts, WithLoadOutput(false)) // Don't load output for queued workflows
643-
opts = append(opts, WithSortDesc())
644-
opts = append(opts, WithQueuesOnly()) // Only include workflows that are in queues
643+
opts = append(opts, WithQueuesOnly()) // Only include workflows that are in queues
645644

646645
// Add status filter for queued workflows
647646
queuedStatuses := make([]WorkflowStatusType, 0)
@@ -658,6 +657,9 @@ func (c *Conductor) handleListQueuedWorkflowsRequest(data []byte, requestID stri
658657
}
659658
opts = append(opts, WithStatus(queuedStatuses))
660659

660+
if req.Body.SortDesc {
661+
opts = append(opts, WithSortDesc())
662+
}
661663
if req.Body.WorkflowName != nil {
662664
opts = append(opts, WithName(*req.Body.WorkflowName))
663665
}

0 commit comments

Comments
 (0)