diff --git a/models/repo_watch.go b/models/repo_watch.go
index 1d6b7a31c..4a8f1af8a 100644
--- a/models/repo_watch.go
+++ b/models/repo_watch.go
@@ -280,8 +280,9 @@ func notifyWatchers(e Engine, actions ...*Action) error {
 // NotifyWatchers creates batch of actions for every watcher.
 func NotifyWatchers(actions ...*Action) error {
 
+	error := notifyWatchers(x, actions...)
 	producer(actions...)
-	return notifyWatchers(x, actions...)
+	return error
 }
 
 func producer(actions ...*Action) {