Skip to content

Commit

Permalink
fixed sharded table
Browse files Browse the repository at this point in the history
  • Loading branch information
kofoworola committed Sep 18, 2023
1 parent 89c762a commit 4be9844
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion pumps/graph_sql_aggregate.go
Original file line number Diff line number Diff line change
Expand Up @@ -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")
}
}
Expand Down

0 comments on commit 4be9844

Please sign in to comment.