Gleipnir/nidus-sync
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Actually exit early on empty aggregate

Browse source 
Previous attempt was subtly wrong.
This commit is contained in:
Eli Ribble 2026-01-14 21:52:36 +00:00
parent a4c0e367a8
commit cd22818240
No known key found for this signature in database
1 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

8
background/arcgis.go
View file

@ -1039,6 +1039,10 @@ func updateSummaryTables(ctx context.Context, org *models.Organization) {
log.Error().Err(err).Msg("Failed to get organization")
return
}
if len(point_locations) == 0 {
log.Info().Int("org_id", int(org.ID)).Msg("No updates to perform")
return
}
log.Info().Int("count", len(point_locations)).Msg("Summarizing point locations")
for i := range 16 {
@ -1075,10 +1079,6 @@ func updateSummaryTables(ctx context.Context, org *models.Organization) {
im.SetCol("count_").To(psql.Raw("EXCLUDED.count_")),
))
//log.Info().Str("sql", insertQueryToString(psql.Insert(to_insert...))).Msg("Updating...")
if len(to_insert) == 0 {
log.Info().Int("resolution", i).Msg("No updates to perform")
continue
}
_, err := psql.Insert(to_insert...).Exec(ctx, db.PGInstance.BobDB)
if err != nil {
log.Error().Err(err).Msg("Faild to add h3 aggregation")