We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ef605a8 commit 9db88e5Copy full SHA for 9db88e5
pkg/openSearch/openSearchClient/client.go
@@ -217,7 +217,8 @@ func (c *Client) SearchStream(
217
clearScrollReq := opensearchapi.ScrollDeleteReq{
218
ScrollIDs: []string{scrollID},
219
}
220
- _, err = c.openSearchProjectClient.Scroll.Delete(ctx, clearScrollReq)
+ detachedCtx := context.WithoutCancel(ctx)
221
+ _, err = c.openSearchProjectClient.Scroll.Delete(detachedCtx, clearScrollReq)
222
if err != nil {
223
log.Warn().Err(err).Msgf("failed to delete scroll context")
224
0 commit comments