Skip to content

Commit ca7670d

Browse files
committed
update tests
1 parent 304240c commit ca7670d

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

dbos/client_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ func TestEnqueue(t *testing.T) {
2121

2222
// Create a priority-enabled queue with max concurrency of 1 to ensure ordering
2323
// Must be created before Launch()
24-
priorityQueue := NewWorkflowQueue(serverCtx, "priority-test-queue", WithGlobalConcurrency(1), WithPriorityEnabled(true))
24+
priorityQueue := NewWorkflowQueue(serverCtx, "priority-test-queue", WithGlobalConcurrency(1), WithPriorityEnabled())
2525

2626
// Track execution order for priority test
2727
var executionOrder []string

dbos/queues_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1140,7 +1140,7 @@ func TestPriorityQueue(t *testing.T) {
11401140
dbosCtx := setupDBOS(t, true, true)
11411141

11421142
// Create priority-enabled queue with max concurrency of 1
1143-
priorityQueue := NewWorkflowQueue(dbosCtx, "test_queue_priority", WithGlobalConcurrency(1), WithPriorityEnabled(true))
1143+
priorityQueue := NewWorkflowQueue(dbosCtx, "test_queue_priority", WithGlobalConcurrency(1), WithPriorityEnabled())
11441144
childQueue := NewWorkflowQueue(dbosCtx, "test_queue_child")
11451145

11461146
workflowEvent := NewEvent()

0 commit comments

Comments
 (0)