Skip to content

Commit 13fc9e9

Browse files
committed
sort steps by ID, list internal queue workflows
1 parent 1095e30 commit 13fc9e9

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

dbos/admin_server.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -356,7 +356,7 @@ func newAdminServer(ctx *dbosContext, port int) *adminServer {
356356
if req.QueueName == nil {
357357
filtered := make([]WorkflowStatus, 0, len(workflows))
358358
for _, wf := range workflows {
359-
if len(wf.QueueName) > 0 && wf.QueueName != _DBOS_INTERNAL_QUEUE_NAME {
359+
if len(wf.QueueName) > 0 {
360360
filtered = append(filtered, wf)
361361
}
362362
}

dbos/system_database.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1227,7 +1227,8 @@ type stepInfo struct {
12271227
func (s *sysDB) getWorkflowSteps(ctx context.Context, workflowID string) ([]stepInfo, error) {
12281228
query := `SELECT function_id, function_name, output, error, child_workflow_id
12291229
FROM dbos.operation_outputs
1230-
WHERE workflow_uuid = $1`
1230+
WHERE workflow_uuid = $1
1231+
ORDER BY function_id ASC`
12311232

12321233
rows, err := s.pool.Query(ctx, query, workflowID)
12331234
if err != nil {

0 commit comments

Comments
 (0)