Skip to content

Commit

Permalink
Skipping tests that are related to Azure#21530
Browse files Browse the repository at this point in the history
  • Loading branch information
Richard Park committed Sep 9, 2023
1 parent bc3b647 commit 7b8b722
Showing 1 changed file with 14 additions and 2 deletions.
16 changes: 14 additions & 2 deletions sdk/messaging/azeventgrid/client_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -75,6 +75,8 @@ func TestFailedAck(t *testing.T) {
})

t.Run("ReleaseCloudEvents", func(t *testing.T) {
t.Skipf("Skipping, server-bug preventing release from working properly. https://github.com/Azure/azure-sdk-for-go/issues/21530")

resp, err := c.ReleaseCloudEvents(context.Background(), c.TestVars.Topic, c.TestVars.Subscription, azeventgrid.ReleaseOptions{
LockTokens: []string{*recvResp.Value[0].BrokerProperties.LockToken},
}, nil)
Expand All @@ -84,8 +86,8 @@ func TestFailedAck(t *testing.T) {
require.Equal(t, []azeventgrid.FailedLockToken{
{
LockToken: recvResp.Value[0].BrokerProperties.LockToken,
ErrorCode: to.Ptr("InternalServerError"),
ErrorDescription: to.Ptr("No result returned for release request."),
ErrorCode: to.Ptr("TokenLost"),
ErrorDescription: to.Ptr("Token has expired."),
},
}, resp.FailedLockTokens)
})
Expand Down Expand Up @@ -169,6 +171,8 @@ func TestReject(t *testing.T) {
}

func TestRelease(t *testing.T) {
t.Skipf("Skipping, server-bug preventing release from working properly. https://github.com/Azure/azure-sdk-for-go/issues/21530")

c := newClientWrapper(t, nil)

ce, err := messaging.NewCloudEvent("TestAbandon", "world", []byte("event one"), nil)
Expand All @@ -188,6 +192,14 @@ func TestRelease(t *testing.T) {
LockTokens: []string{*events.Value[0].BrokerProperties.LockToken},
}, nil)
require.NoError(t, err)

if len(rejectResp.FailedLockTokens) > 0 {
for _, flt := range rejectResp.FailedLockTokens {
t.Logf("FailedLockToken:\n ec: %s\n desc: %s\n locktoken:%s", *flt.ErrorCode, *flt.ErrorDescription, *flt.LockToken)
}
require.Fail(t, "Failed to release events")
}

require.Empty(t, rejectResp.FailedLockTokens)

events, err = c.ReceiveCloudEvents(context.Background(), c.TestVars.Topic, c.TestVars.Subscription, nil)
Expand Down

0 comments on commit 7b8b722

Please sign in to comment.