5002-manual check execution bugfix

sensu · Jan 21, 2024 · a5cfeda · a5cfeda
1 parent 4731b2b
commit a5cfeda
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/backend/schedulerd/executor.go b/backend/schedulerd/executor.go
@@ -198,7 +198,9 @@ func (a *AdhocRequestExecutor) listenQueue(ctx context.Context) {
 			continue
 		}
 
-		if err = a.processCheck(ctx, &check); err != nil {
+		//create new context
+		newCtx := corev2.SetContextFromResource(ctx, &check)
+		if err = a.processCheck(newCtx, &check); err != nil {
 			select {
 			case a.listenQueueErr <- err:
 			case <-ctx.Done():
@@ -306,6 +308,10 @@ func processCheck(ctx context.Context, executor Executor, check *corev2.CheckCon
 		}
 		// publish proxy requests on matching entities
 		if matchedEntities := matchEntities(entities, check.ProxyRequests); len(matchedEntities) != 0 {
+			//display matched entities
+			matchedEntityJson, _ := json.Marshal(matchedEntities)q
+			matchedEntityJsonData := string(matchedEntityJson)
+			logger.WithFields(fields).Infof("matched entities: %s", matchedEntityJsonData)
 			if err := executor.publishProxyCheckRequests(matchedEntities, check); err != nil {
 				logger.WithFields(fields).WithError(err).Error("error publishing proxy check requests")
 			}