Extend ci_operator_metrics table with pod-scaler fields

deepsm007 · deepsm007 · commit c0b2961fa941 · 2026-01-12T16:00:54.000-05:00
diff --git a/cmd/pod-scaler/producer.go b/cmd/pod-scaler/producer.go
@@ -646,6 +646,7 @@ type bigQueryPodMetricsRow struct {
 }
 
 func writeMeasuredPodsToBigQuery(ctx context.Context, bqClient *bigquery.Client, projectID, datasetID string, pods []measuredPodData, logger *logrus.Entry) error {
+	// Use ci_operator_metrics table with additional fields for measured pod data
 	inserter := bqClient.Dataset(datasetID).Table("ci_operator_metrics").Inserter()
 
 	// Convert to BigQuery rows

Original file line number	Diff line number	Diff line change
`@@ -646,6 +646,7 @@ type bigQueryPodMetricsRow struct {`
`646`	`646`	`}`
`647`	`647`
`648`	`648`	`func writeMeasuredPodsToBigQuery(ctx context.Context, bqClient bigquery.Client, projectID, datasetID string, pods []measuredPodData, logger logrus.Entry) error {`
	`649`	`+ // Use ci_operator_metrics table with additional fields for measured pod data`
`649`	`650`	`inserter := bqClient.Dataset(datasetID).Table("ci_operator_metrics").Inserter()`
`650`	`651`
`651`	`652`	`// Convert to BigQuery rows`