Skip to content

Commit 1942853

Browse files
author
daveaugustus
committed
test fixed
Signed-off-by: daveaugustus <[email protected]>
1 parent 360882d commit 1942853

File tree

1 file changed

+3
-3
lines changed
  • components/ingest-service/server

1 file changed

+3
-3
lines changed

components/ingest-service/server/chef.go

+3-3
Original file line numberDiff line numberDiff line change
@@ -247,9 +247,9 @@ func (s *ChefIngestServer) ProcessNodeDelete(ctx context.Context,
247247
return &response.ProcessNodeDeleteResponse{}, nil
248248
}
249249

250-
func (s *ChefIngestServer) GetIndicesEligableForReindexing() (map[string]backend.IndexSettingsVersion, error) {
250+
func (s *ChefIngestServer) GetIndicesEligableForReindexing(ctx context.Context) (map[string]backend.IndexSettingsVersion, error) {
251251
var eligableIndices = make(map[string]backend.IndexSettingsVersion)
252-
indices, err := s.client.GetIndices(context.Background())
252+
indices, err := s.client.GetIndices(ctx)
253253
if err != nil {
254254
return nil, status.Errorf(codes.Internal, "failed to fetch indices: %s", err)
255255
}
@@ -283,7 +283,7 @@ OuterLoop:
283283
func (s *ChefIngestServer) StartReindex(ctx context.Context, req *ingest.StartReindexRequest) (*ingest.StartReindexResponse, error) {
284284
log.Info("Received request to start reindexing")
285285

286-
indices, err := s.GetIndicesEligableForReindexing()
286+
indices, err := s.GetIndicesEligableForReindexing(ctx)
287287

288288
if err != nil {
289289
return nil, status.Errorf(codes.Internal, "failed to fetch indices: %s", err)

0 commit comments

Comments
 (0)