diff --git a/pkg/es/search.go b/pkg/es/search.go index 8d3cec3..6164712 100644 --- a/pkg/es/search.go +++ b/pkg/es/search.go @@ -135,6 +135,10 @@ func searchPit(conf *cfg.Config, req *search.Request) error { for { res, err := search.Do(ctx) if err != nil { + if strings.Contains(err.Error(), "reason: all shards failed") { + return nil + } + return fmt.Errorf("failed to run search (esdsl pit): %s", err) }