diff --git a/src/topics/posts.js b/src/topics/posts.js
index 7cecf809b9..a89f368782 100644
--- a/src/topics/posts.js
+++ b/src/topics/posts.js
@@ -175,6 +175,9 @@ module.exports = function(Topics) {
 
 	Topics.addPostToTopic = function(tid, pid, timestamp, votes, callback) {
 		Topics.getTopicField(tid, 'mainPid', function(err, mainPid) {
+			if (err) {
+				return callback(err);
+			}
 			if (!parseInt(mainPid, 10)) {
 				Topics.setTopicField(tid, 'mainPid', pid, callback);
 			} else {