diff --git a/internal/pkg/convert/convert.go b/internal/pkg/convert/convert.go index 6d43b65..f2566a5 100644 --- a/internal/pkg/convert/convert.go +++ b/internal/pkg/convert/convert.go @@ -355,13 +355,20 @@ func getN9MetricSource(m v1.MetricSource) (nobl9v1alpha.MetricSpec, error) { Query: &query, }, } - case supportedMetricSources["Prometheus"], supportedMetricSources["AmazonPrometheus"]: + case supportedMetricSources["Prometheus"]: query := m.MetricSourceSpec["promql"] ms = nobl9v1alpha.MetricSpec{ Prometheus: &nobl9v1alpha.PrometheusMetric{ PromQL: &query, }, } + case supportedMetricSources["AmazonPrometheus"]: + query := m.MetricSourceSpec["promql"] + ms = nobl9v1alpha.MetricSpec{ + AmazonPrometheus: &nobl9v1alpha.AmazonPrometheusMetric{ + PromQL: &query, + }, + } case supportedMetricSources["NewRelic"]: query := m.MetricSourceSpec["nrql"] ms = nobl9v1alpha.MetricSpec{