From 4be9844c96f3d9b140682f691e52d77b42581ec9 Mon Sep 17 00:00:00 2001 From: Kofo Okesola Date: Mon, 18 Sep 2023 06:02:20 +0100 Subject: [PATCH] fixed sharded table --- pumps/graph_sql_aggregate.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pumps/graph_sql_aggregate.go b/pumps/graph_sql_aggregate.go index b90ec4ed9..64fd74a1a 100644 --- a/pumps/graph_sql_aggregate.go +++ b/pumps/graph_sql_aggregate.go @@ -115,7 +115,7 @@ func (s *GraphSQLAggregatePump) WriteData(ctx context.Context, data []interface{ table = analytics.AggregateGraphSQLTable + "_" + recDate s.db = s.db.Table(table) if !s.db.Migrator().HasTable(table) { - if err := s.db.AutoMigrate(&analytics.SQLAnalyticsRecordAggregate{}); err != nil { + if err := s.db.AutoMigrate(&analytics.GraphSQLAnalyticsRecordAggregate{}); err != nil { s.log.WithError(err).Warn("error running auto migration") } }