File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -58,9 +58,9 @@ func WithGlobalConcurrency(concurrency int) QueueOption {
5858
5959// WithPriorityEnabled enables priority-based scheduling for the queue.
6060// When enabled, workflows with lower priority numbers are executed first.
61- func WithPriorityEnabled (enabled bool ) QueueOption {
61+ func WithPriorityEnabled () QueueOption {
6262 return func (q * WorkflowQueue ) {
63- q .PriorityEnabled = enabled
63+ q .PriorityEnabled = true
6464 }
6565}
6666
@@ -92,7 +92,7 @@ func WithMaxTasksPerIteration(maxTasks int) QueueOption {
9292// Limit: 100,
9393// Period: 60.0, // 100 workflows per minute
9494// }),
95- // dbos.WithPriorityEnabled(true ),
95+ // dbos.WithPriorityEnabled(),
9696// )
9797//
9898// // Enqueue workflows to this queue:
You can’t perform that action at this time.
0 commit comments