diff options
Diffstat (limited to 'models/repo_watch.go')
| -rw-r--r-- | models/repo_watch.go | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/models/repo_watch.go b/models/repo_watch.go index 55fb08a426..fb1b1086aa 100644 --- a/models/repo_watch.go +++ b/models/repo_watch.go @@ -290,17 +290,17 @@ func NotifyWatchers(actions ...*Action) error { // NotifyWatchersActions creates batch of actions for every watcher. func NotifyWatchersActions(acts []*Action) error { - sess := db.NewSession(db.DefaultContext) - defer sess.Close() - if err := sess.Begin(); err != nil { + ctx, committer, err := db.TxContext() + if err != nil { return err } + defer committer.Close() for _, act := range acts { - if err := notifyWatchers(sess, act); err != nil { + if err := notifyWatchers(db.GetEngine(ctx), act); err != nil { return err } } - return sess.Commit() + return committer.Commit() } func watchIfAuto(e db.Engine, userID, repoID int64, isWrite bool) error { |