@@ -1295,15 +1295,15 @@ func sendWorkflow(ctx DBOSContext, input sendWorkflowInput) (string, error) {
12951295}
12961296
12971297func receiveWorkflow (ctx DBOSContext , topic string ) (string , error ) {
1298- msg1 , err := Recv [string ](ctx , WorkflowRecvInput {Topic : topic , Timeout : 3 * time .Second })
1298+ msg1 , err := Recv [string ](ctx , WorkflowRecvInput {Topic : topic , Timeout : 10 * time .Second })
12991299 if err != nil {
13001300 return "" , err
13011301 }
1302- msg2 , err := Recv [string ](ctx , WorkflowRecvInput {Topic : topic , Timeout : 3 * time .Second })
1302+ msg2 , err := Recv [string ](ctx , WorkflowRecvInput {Topic : topic , Timeout : 10 * time .Second })
13031303 if err != nil {
13041304 return "" , err
13051305 }
1306- msg3 , err := Recv [string ](ctx , WorkflowRecvInput {Topic : topic , Timeout : 3 * time .Second })
1306+ msg3 , err := Recv [string ](ctx , WorkflowRecvInput {Topic : topic , Timeout : 10 * time .Second })
13071307 if err != nil {
13081308 return "" , err
13091309 }
@@ -1601,7 +1601,7 @@ func TestSendRecv(t *testing.T) {
16011601 t .Fatalf ("failed to start receive workflow: %v" , err )
16021602 }
16031603
1604- // Send messages from outside a workflow context (should work now)
1604+ // Send messages from outside a workflow context
16051605 for i := range 3 {
16061606 err = Send (dbosCtx , GenericWorkflowSendInput [string ]{
16071607 DestinationID : receiveHandle .GetWorkflowID (),
0 commit comments