Skip to content

Commit 9ae3056

Browse files
dev: fix flap tests in PoolingSessionTests.cs (#493)
1 parent b238264 commit 9ae3056

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

src/Ydb.Sdk/test/Ydb.Sdk.Ado.Tests/Session/PoolingSessionTests.cs

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -101,6 +101,7 @@ public async Task Open_WhenAttachStreamFirstMoveNextAsyncThrowException_IsBroken
101101
var ydbException = await Assert.ThrowsAsync<YdbException>(() => session.Open(CancellationToken.None));
102102
Assert.Equal("Transport RPC call error", ydbException.Message);
103103
Assert.Equal(StatusCode.ClientTransportTimeout, ydbException.Code);
104+
await Task.Delay(500);
104105
Assert.True(session.IsBroken);
105106
}
106107

@@ -113,6 +114,7 @@ public async Task Open_WhenAttachStreamFirstMoveNextIsFalse_IsBroken()
113114
var ydbException = await Assert.ThrowsAsync<YdbException>(() => session.Open(CancellationToken.None));
114115
Assert.Equal("Attach stream is not started!", ydbException.Message);
115116
Assert.Equal(StatusCode.Cancelled, ydbException.Code);
117+
await Task.Delay(500);
116118
Assert.True(session.IsBroken);
117119
}
118120

@@ -133,6 +135,7 @@ public async Task Open_WhenAttachStreamFirstCurrentIsBadSession_IsBroken()
133135
var ydbException = await Assert.ThrowsAsync<YdbException>(() => session.Open(CancellationToken.None));
134136
Assert.Equal("Status: BadSession, Issues:\n[1] Error: Ouch BadSession!", ydbException.Message);
135137
Assert.Equal(StatusCode.BadSession, ydbException.Code);
138+
await Task.Delay(500);
136139
Assert.True(session.IsBroken);
137140
}
138141

@@ -150,7 +153,7 @@ public async Task Open_WhenSuccessOpenThenAttachStreamIsClosed_IsBroken()
150153
}
151154

152155
[Fact]
153-
public async Task Open_WhenSuccessOpenThenAttachStreamSendRpcException_IsNotBroken()
156+
public async Task Open_WhenSuccessOpenThenAttachStreamSendRpcException_IsBroken()
154157
{
155158
SetupSuccessCreateSession();
156159
var tcsSecondMoveAttachStream = SetupAttachStream();
@@ -164,7 +167,7 @@ public async Task Open_WhenSuccessOpenThenAttachStreamSendRpcException_IsNotBrok
164167
}
165168

166169
[Fact]
167-
public async Task Open_WhenSuccessOpenThenAttachStreamSendBadSession_IsNotBroken()
170+
public async Task Open_WhenSuccessOpenThenAttachStreamSendBadSession_IsBroken()
168171
{
169172
SetupSuccessCreateSession();
170173
var tcsSecondMoveAttachStream = SetupAttachStream();

0 commit comments

Comments
 (0)