Skip to content

Commit 7c9a866

Browse files
committed
very long timeouts
1 parent 1660da1 commit 7c9a866

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

dbos/dbos_test.go

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -436,7 +436,7 @@ func TestCustomSystemDBSchema(t *testing.T) {
436436
}
437437

438438
// Wait for an event from the partner workflow
439-
result, err := GetEvent[string](ctx, input.PartnerWorkflowID, "response-key", 5*time.Second)
439+
result, err := GetEvent[string](ctx, input.PartnerWorkflowID, "response-key", 5*time.Hour)
440440
if err != nil {
441441
return "", err
442442
}
@@ -447,11 +447,13 @@ func TestCustomSystemDBSchema(t *testing.T) {
447447
// Workflow B: Uses Recv() and SetEvent() - waits for workflow A
448448
recvSetEventWorkflow := func(ctx DBOSContext, input testWorkflowInput) (string, error) {
449449
// Receive a message from the partner workflow
450-
receivedMsg, err := Recv[string](ctx, "test-topic", 5*time.Second)
450+
receivedMsg, err := Recv[string](ctx, "test-topic", 5*time.Hour)
451451
if err != nil {
452452
return "", err
453453
}
454454

455+
time.Sleep(1 * time.Second)
456+
455457
// Set an event for the partner workflow
456458
err = SetEvent(ctx, "response-key", "response-from-workflow-b")
457459
if err != nil {

0 commit comments

Comments
 (0)