Skip to content

Commit 0ba6333

Browse files
vr-varadmaxdml
authored andcommitted
Fix: Update
1 parent 87fba81 commit 0ba6333

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
@@ -367,10 +367,8 @@ func TestWorkflowQueues(t *testing.T) {
367367
// Check the workflow completes
368368
dlqCompleteEvent.Set()
369369
for _, handle := range handles {
370-
result, err := handle.GetResult()
371-
fmt.Print(result)
372-
fmt.Print(err)
373-
// assert.Equal(t, WorkflowStatusMaxRecoveryAttemptsExceeded, err.Status, "expected workflow to be in DLQ after max retries exceeded")
370+
_, err := handle.GetResult()
371+
assert.Equal(t, "Awaited workflow blocking-workflow-test has exceeded the maximum number of step retries", err)
374372
}
375373

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

0 commit comments

Comments
 (0)