Skip to content

Commit 6965cf4

Browse files
codebrainrusscam
authored andcommitted
Fix bulk timeout.
1 parent d02cb29 commit 6965cf4

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

src/Nest/Document/Multiple/BulkAll/BulkAllObservable.cs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -116,6 +116,7 @@ private async Task<BulkAllResponse> BulkAsync(IList<T> buffer, long page, int ba
116116
var response = await _client.BulkAsync(s =>
117117
{
118118
s.Index(request.Index);
119+
s.Timeout(request.Timeout);
119120
if (request.BufferToBulk != null) request.BufferToBulk(s, buffer);
120121
else s.IndexMany(buffer);
121122
if (!string.IsNullOrEmpty(request.Pipeline)) s.Pipeline(request.Pipeline);

0 commit comments

Comments
 (0)