Merge branch 'main' into PLEX-1878

Author: Unheilbar

pkg/workflows/wasm/host/standard_test.go

@@ -95,16 +95,19 @@ func TestStandardCapabilityCallsAreAsync(t *testing.T) {
 		assert.Equal(t, "PerformAction", request.Method)
 		input := &basicaction.Inputs{}
 		assert.NoError(t, request.Payload.UnmarshalTo(input))
-		assert.False(t, callsSeen[input.InputThing])
-		callsSeen[input.InputThing] = true
-		payload, err := anypb.New(&basicaction.Outputs{AdaptedThing: fmt.Sprintf("%t", input.InputThing)})
-		require.NoError(t, err)
 
 		// Don't return until the second call has been executed
+		// Take the lock before accessing callsSeen to avoid a race
 		if input.InputThing {
 			mt.Lock()
 		}
 		defer mt.Unlock()
+
+		assert.False(t, callsSeen[input.InputThing])
+		callsSeen[input.InputThing] = true
+		payload, err := anypb.New(&basicaction.Outputs{AdaptedThing: fmt.Sprintf("%t", input.InputThing)})
+		require.NoError(t, err)
+
 		return &sdk.CapabilityResponse{
 			Response: &sdk.CapabilityResponse_Payload{Payload: payload},
 		}, nil