Skip to content

Commit 09ef4e7

Browse files
committed
Fix: Update
1 parent 8104934 commit 09ef4e7

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

dbos/queues_test.go

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -366,10 +366,8 @@ func TestWorkflowQueues(t *testing.T) {
366366
// Check the workflow completes
367367
dlqCompleteEvent.Set()
368368
for _, handle := range handles {
369-
result, err := handle.GetResult()
370-
fmt.Print(result)
371-
fmt.Print(err)
372-
// assert.Equal(t, WorkflowStatusMaxRecoveryAttemptsExceeded, err.Status, "expected workflow to be in DLQ after max retries exceeded")
369+
_, err := handle.GetResult()
370+
assert.Equal(t, "Awaited workflow blocking-workflow-test has exceeded the maximum number of step retries", err)
373371
}
374372

375373
require.True(t, queueEntriesAreCleanedUp(dbosCtx), "expected queue entries to be cleaned up after successive enqueues test")

0 commit comments

Comments
 (0)