chore(api): remove BigQuery MlObs sink option

api/config/observability.go

@@ -8,7 +8,6 @@ import (
 // ObservabilityPublisher
 type ObservabilityPublisher struct {
 	ArizeSink                ArizeSink
-	BigQuerySink             BigQuerySink
 	MaxComputeSink           MaxComputeSink
 	KafkaConsumer            KafkaConsumer
 	ImageName                string
@@ -46,14 +45,6 @@ func (az ArizeSink) IsEnabled(modelSerial string) bool {
 	return false
 }
 
-// BigQuerySink
-type BigQuerySink struct {
-	Project string
-	Dataset string
-	TTLDays int
-	Enabled bool
-}
-
 // MaxComputeSink
 type MaxComputeSink struct {
 	Project         string

api/pkg/observability/deployment/config.go

@@ -49,12 +49,6 @@ type ArizeSink struct {
 	SpaceKey string `yaml:"space_key"`
 }
 
-type BigQuerySink struct {
-	Project string `yaml:"project"`
-	Dataset string `yaml:"dataset"`
-	TTLDays int    `yaml:"ttl_days"`
-}
-
 type MaxComputeSink struct {
 	Project         string `yaml:"project"`
 	Dataset         string `yaml:"dataset"`

api/pkg/observability/deployment/deployment.go

@@ -262,16 +262,6 @@ func (c *deployer) applySecret(ctx context.Context, data *models.WorkerData) (se
 
 func (c *deployer) createSecretSpec(data *models.WorkerData) (*corev1.Secret, error) {
 	observationSinks := []ObservationSink{}
-	if c.consumerConfig.BigQuerySink.Enabled {
-		observationSinks = append(observationSinks, ObservationSink{
-			Type: BQ,
-			Config: BigQuerySink{
-				Project: c.consumerConfig.BigQuerySink.Project,
-				Dataset: c.consumerConfig.BigQuerySink.Dataset,
-				TTLDays: c.consumerConfig.BigQuerySink.TTLDays,
-			},
-		})
-	}
 	if c.consumerConfig.MaxComputeSink.Enabled {
 		observationSinks = append(observationSinks, ObservationSink{
 			Type: MaxCompute,
@@ -429,7 +419,7 @@ func (c *deployer) createDeploymentSpec(data *models.WorkerData, secretName stri
 			},
 		},
 	}
-	podSpecWithIdentity := enrichIdentityToPod(podSpec, c.consumerConfig.ServiceAccountSecretName, []string{workerContainer})
+
 	numReplicas := c.consumerConfig.Replicas
 	if data.ResourceRequest != nil && data.ResourceRequest.Replica > 0 {
 		numReplicas = data.ResourceRequest.Replica
@@ -458,7 +448,7 @@ func (c *deployer) createDeploymentSpec(data *models.WorkerData, secretName stri
 						PublisherRevisionAnnotationKey: strconv.Itoa(data.Revision),
 					},
 				},
-				Spec: podSpecWithIdentity,
+				Spec: podSpec,
 			},
 		},
 	}, nil