chore: remove namespace tag from measurements (#3468)

rudderlabs · Jun 8, 2023 · a6ac7bd · a6ac7bd
1 parent 34f4c0d
commit a6ac7bd
Show file tree

Hide file tree

Showing 8 changed files with 0 additions and 10 deletions.
diff --git a/enterprise/reporting/error_reporting.go b/enterprise/reporting/error_reporting.go
@@ -322,7 +322,6 @@ func (edRep *ErrorDetailReporter) getDBHandle(clientName string) (*sql.DB, error
 func (edRep *ErrorDetailReporter) getTags(clientName string) stats.Tags {
 	return stats.Tags{
 		"workspaceID": edRep.workspaceID,
-		"namespace":   edRep.namespace,
 		"clientName":  clientName,
 		"instanceId":  edRep.instanceID,
 	}

diff --git a/enterprise/reporting/reporting.go b/enterprise/reporting/reporting.go
@@ -603,7 +603,6 @@ func (r *HandleT) Report(metrics []*types.PUReportedMetric, txn *sql.Tx) {
 
 func (r *HandleT) getTags(clientName string) stats.Tags {
 	return stats.Tags{
-		"namespace":   r.namespace,
 		"workspaceId": r.workspaceID,
 		"instanceId":  r.instanceID,
 		"clientName":  clientName,

diff --git a/warehouse/integrations/clickhouse/clickhouse.go b/warehouse/integrations/clickhouse/clickhouse.go
@@ -189,7 +189,6 @@ func (ch *Clickhouse) newClickHouseStat(tableName string) *clickHouseStat {
 		"destination": warehouse.Destination.ID,
 		"destType":    warehouse.Type,
 		"source":      warehouse.Source.ID,
-		"namespace":   warehouse.Namespace,
 		"identifier":  warehouse.Identifier,
 		"tableName":   tableName,
 	}

diff --git a/warehouse/integrations/deltalake-native/deltalake.go b/warehouse/integrations/deltalake-native/deltalake.go
@@ -755,7 +755,6 @@ func (d *Deltalake) loadTable(ctx context.Context, tableName string, tableSchema
 		"destID":      d.Warehouse.Destination.ID,
 		"destType":    d.Warehouse.Destination.DestinationDefinition.Name,
 		"workspaceId": d.Warehouse.WorkspaceID,
-		"namespace":   d.Namespace,
 		"tableName":   tableName,
 	}).Count(int(updated))
 
@@ -1129,7 +1128,6 @@ func (d *Deltalake) LoadUserTables(ctx context.Context) map[string]error {
 		"destID":      d.Warehouse.Destination.ID,
 		"destType":    d.Warehouse.Destination.DestinationDefinition.Name,
 		"workspaceId": d.Warehouse.WorkspaceID,
-		"namespace":   d.Namespace,
 		"tableName":   warehouseutils.UsersTable,
 	}).Count(int(updated))
 

diff --git a/warehouse/integrations/postgres-legacy/postgres.go b/warehouse/integrations/postgres-legacy/postgres.go
@@ -670,7 +670,6 @@ func (pg *Postgres) loadUserTables(ctx context.Context) (errorMap map[string]err
 	// tags
 	tags := stats.Tags{
 		"workspaceId": pg.Warehouse.WorkspaceID,
-		"namespace":   pg.Namespace,
 		"destId":      pg.Warehouse.Destination.ID,
 		"tableName":   warehouseutils.UsersTable,
 	}

diff --git a/warehouse/integrations/postgres/load.go b/warehouse/integrations/postgres/load.go
@@ -239,7 +239,6 @@ func (pg *Postgres) loadTable(
 			"destID":       pg.Warehouse.Destination.ID,
 			"destType":     pg.Warehouse.Destination.DestinationDefinition.Name,
 			"workspaceId":  pg.Warehouse.WorkspaceID,
-			"namespace":    pg.Namespace,
 			"tableName":    tableName,
 			"rowsAffected": fmt.Sprintf("%d", rowsAffected),
 		})

diff --git a/warehouse/integrations/redshift/redshift.go b/warehouse/integrations/redshift/redshift.go
@@ -682,7 +682,6 @@ func (rs *Redshift) loadTable(ctx context.Context, tableName string, tableSchema
 			"destID":      rs.Warehouse.Destination.ID,
 			"destType":    rs.Warehouse.Destination.DestinationDefinition.Name,
 			"workspaceId": rs.Warehouse.WorkspaceID,
-			"namespace":   rs.Namespace,
 			"tableName":   tableName,
 		}).Count(int(rowsAffected))
 	}

diff --git a/warehouse/integrations/snowflake/snowflake.go b/warehouse/integrations/snowflake/snowflake.go
@@ -569,7 +569,6 @@ func (sf *Snowflake) loadTable(ctx context.Context, tableName string, tableSchem
 		"destID":      sf.Warehouse.Destination.ID,
 		"destType":    sf.Warehouse.Destination.DestinationDefinition.Name,
 		"workspaceId": sf.Warehouse.WorkspaceID,
-		"namespace":   sf.Namespace,
 		"tableName":   tableName,
 	}).Count(int(updated))
 
@@ -932,7 +931,6 @@ func (sf *Snowflake) loadUserTables(ctx context.Context) map[string]error {
 		"destID":      sf.Warehouse.Destination.ID,
 		"destType":    sf.Warehouse.Destination.DestinationDefinition.Name,
 		"workspaceId": sf.Warehouse.WorkspaceID,
-		"namespace":   sf.Namespace,
 		"tableName":   warehouseutils.UsersTable,
 	}).Count(int(updated))