twhelp/dataupdater
Archived
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

add a timeout to the transaction responsible for saving the updated server data

Browse Source
This commit is contained in:
Dawid Wysokiński 2021-05-01 16:21:49 +02:00
parent 6008d9250c
commit 443c7fb537
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
internal/cron/tasks/task_update_server_data.go
View File

@ -277,7 +277,9 @@ func (w *workerUpdateServerData) update() error {
return errors.Wrap(err, "workerUpdateServerData.update") return errors.Wrap(err, "workerUpdateServerData.update")
} }
return w.db.RunInTransaction(context.Background(), func(tx *pg.Tx) error { ctx, cancel := context.WithTimeout(context.Background(), 20*time.Second)
defer cancel()
return w.db.RunInTransaction(ctx, func(tx *pg.Tx) error {
if len(tribesResult.deletedTribes) > 0 { if len(tribesResult.deletedTribes) > 0 {
if _, err := tx.Model(&models.Tribe{}). if _, err := tx.Model(&models.Tribe{}).
Where("tribe.id = ANY (?)", pg.Array(tribesResult.deletedTribes)). Where("tribe.id = ANY (?)", pg.Array(tribesResult.deletedTribes)).