File tree Expand file tree Collapse file tree 1 file changed +8
-4
lines changed Expand file tree Collapse file tree 1 file changed +8
-4
lines changed Original file line number Diff line number Diff line change 22using System . Data . Common ;
33using System . Diagnostics . CodeAnalysis ;
44using Ydb . Operations ;
5+ using Ydb . Sdk . Ado . Internal ;
56using Ydb . Sdk . Ado . Session ;
67using Ydb . Sdk . Services . Query ;
78using Ydb . Sdk . Value ;
@@ -83,8 +84,7 @@ public async Task BulkUpsertAsync(
8384 var req = new BulkUpsertRequest
8485 {
8586 Table = tablePath ,
86- Rows = list . GetProto ( ) ,
87- OperationParams = new OperationParams ( )
87+ Rows = list . GetProto ( )
8888 } ;
8989
9090 if ( Session is Services . Query . Session sessionImpl )
@@ -94,8 +94,12 @@ public async Task BulkUpsertAsync(
9494 req ,
9595 new GrpcRequestSettings { CancellationToken = cancellationToken }
9696 ) . ConfigureAwait ( false ) ;
97- var status = Status . FromProto ( resp . Operation . Status , resp . Operation . Issues ) ;
98- status . EnsureSuccess ( ) ;
97+
98+ var operation = resp . Operation ;
99+ if ( operation . Status . IsNotSuccess ( ) )
100+ {
101+ throw YdbException . FromServer ( operation . Status , operation . Issues ) ;
102+ }
99103 }
100104 else
101105 {
You can’t perform that action at this time.
0 commit comments