fix uniqueness of flights per day

explore-flights · Aug 24, 2024 · d13cd1e · d13cd1e
1 parent bfc0999
commit d13cd1e
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/go/cron/action/convert_flight_schedules.go b/go/cron/action/convert_flight_schedules.go
@@ -141,8 +141,10 @@ func (a *cfsAction) upsertFlights(ctx context.Context, bucket, prefix string, d
 	result := make([]*common.Flight, 0, max(len(flights), len(existing)))
 
 	for _, f := range flights {
-		result = append(result, f)
-		added[f.Id()] = struct{}{}
+		if _, ok := added[f.Id()]; !ok {
+			result = append(result, f)
+			added[f.Id()] = struct{}{}
+		}
 	}
 
 	for _, f := range existing {