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

Drop to a single worker in the geocode pool

Browse source 
I'm sharing transactions incorrectly, and until I fix that I need
correctness, not speed.
This commit is contained in:
Eli Ribble 2026-04-16 23:50:19 +00:00
parent 5100c8f0be
commit 6945b9f9ed
No known key found for this signature in database
1 changed files with 8 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

12
platform/csv/pool.go
View file

@ -80,10 +80,14 @@ func bulkGeocode(ctx context.Context, txn bob.Tx, file *models.FileuploadFile, c
errors := make(chan error, len(pools))
var wg sync.WaitGroup
for i := 0; i < 20; i++ {
wg.Add(1)
go worker(ctx, txn, client, jobs, errors, &wg)
}
/*
for i := 0; i < 20; i++ {
wg.Add(1)
go worker(ctx, txn, client, jobs, errors, &wg)
}
*/
wg.Add(1)
go worker(ctx, txn, client, jobs, errors, &wg)
for _, pool := range pools {
jobs <- &jobGeocode{