Merge pull request #2326 from opengovern/fix-tasks

fix: fix ListQueryParameters calls
opengovern · Dec 29, 2024 · 1af0828 · 1af0828
2 parents dd3086a + cb844e8
commit 1af0828
Show file tree

Hide file tree

Showing 5 changed files with 6 additions and 6 deletions.
diff --git a/jobs/compliance-quick-run-job/query_result.go b/jobs/compliance-quick-run-job/query_result.go
@@ -50,7 +50,7 @@ func (w *Worker) RunQuery(ctx context.Context, j QueryJob) ([]QueryResult, error
 		return nil, err
 	}
 	queryParamMap := make(map[string]string)
-	for _, qp := range queryParams.QueryParameters {
+	for _, qp := range queryParams.Items {
 		queryParamMap[qp.Key] = qp.Value
 	}
 

diff --git a/jobs/compliance-runner-job/job.go b/jobs/compliance-runner-job/job.go
@@ -97,7 +97,7 @@ func (w *Worker) RunJob(ctx context.Context, j Job) (int, error) {
 		return 0, err
 	}
 	queryParamMap := make(map[string]string)
-	for _, qp := range queryParams.QueryParameters {
+	for _, qp := range queryParams.Items {
 		queryParamMap[qp.Key] = qp.Value
 	}
 

diff --git a/services/describe/schedulers/query-runner/publisher.go b/services/describe/schedulers/query-runner/publisher.go
@@ -70,7 +70,7 @@ func (s *JobScheduler) runPublisher(ctx context.Context) error {
 			return err
 		}
 		queryParamMap := make(map[string]string)
-		for _, qp := range queryParams.QueryParameters {
+		for _, qp := range queryParams.Items {
 			queryParamMap[qp.Key] = qp.Value
 		}
 		queryTemplate, err := template.New("query").Parse(query)

diff --git a/services/describe/schedulers/query-validator/publisher.go b/services/describe/schedulers/query-validator/publisher.go
@@ -86,7 +86,7 @@ func (s *JobScheduler) runPublisher(ctx context.Context) error {
 			return err
 		}
 		queryParamMap := make(map[string]string)
-		for _, qp := range queryParams.QueryParameters {
+		for _, qp := range queryParams.Items {
 			queryParamMap[qp.Key] = qp.Value
 		}
 		queryTemplate, err := template.New(jobMsg.QueryId).Parse(jobMsg.Query)

diff --git a/services/inventory/http_routes.go b/services/inventory/http_routes.go
@@ -494,7 +494,7 @@ func (h *HttpHandler) RunQuery(ctx echo.Context) error {
 		return err
 	}
 	queryParamMap := make(map[string]string)
-	for _, qp := range queryParams.QueryParameters {
+	for _, qp := range queryParams.Items {
 		queryParamMap[qp.Key] = qp.Value
 	}
 
@@ -1163,7 +1163,7 @@ func (h *HttpHandler) RunQueryByID(ctx echo.Context) error {
 		return echo.NewHTTPError(http.StatusInternalServerError, "failed to get query parameters")
 	}
 	queryParamMap := make(map[string]string)
-	for _, qp := range queryParams.QueryParameters {
+	for _, qp := range queryParams.Items {
 		queryParamMap[qp.Key] = qp.Value
 	}