Changes from review

Author: justinkaseman

pkg/workflows/wasm/host/execution_await_order_test.go

@@ -69,7 +69,7 @@ func TestAwaitCapabilities_headOfLineBlocksOnEarlierID(t *testing.T) {
 	exec := &execution[*sdkpb.ExecutionResult]{
 		ctx:                 t.Context(),
 		capabilityResponses: make(map[int32]<-chan *sdkpb.CapabilityResponse),
-		pendingCallsSem:     make(chan struct{}, 100),
+		pendingCallsSem:     make(chan struct{}, defaultMaxPendingCalls),
 		executor:            stub,
 	}
 

pkg/workflows/wasm/host/module.go

@@ -42,7 +42,7 @@ var (
 	defaultMinMemoryMBs              = uint64(128)
 	DefaultInitialFuel               = uint64(100_000_000)
 	defaultMaxFetchRequests          = 5
-	defaultMaxPendingCalls           = 30 // matches engine CapabilityConcurrencyLimit default
+	defaultMaxPendingCalls           = 30                // matches engine CapabilityConcurrencyLimit default
 	defaultMaxCompressedBinarySize   = 20 * 1024 * 1024  // 20 MB
 	defaultMaxDecompressedBinarySize = 100 * 1024 * 1024 // 100 MB
 	defaultMaxResponseSizeBytes      = 5 * 1024 * 1024   // 5 MB

pkg/workflows/wasm/host/module_test.go

@@ -633,7 +633,7 @@ func Test_CallAwaitRace(t *testing.T) {
 	exec := &execution[*wasmpb.ExecutionResult]{
 		module:              m,
 		capabilityResponses: map[int32]<-chan *sdkpb.CapabilityResponse{},
-		pendingCallsSem:     make(chan struct{}, 100),
+		pendingCallsSem:     make(chan struct{}, defaultMaxPendingCalls),
 		ctx:                 t.Context(),
 		executor:            mockExecHelper,
 	}