diff --git a/reindexer.go b/reindexer.go
index 7193a1337..fed5d513c 100644
--- a/reindexer.go
+++ b/reindexer.go
@@ -192,6 +192,9 @@ func (ix *Reindexer) Do() (*ReindexerResponse, error) {
 		scanner = scanner.Size(ix.size)
 	}
 	cursor, err := scanner.Do()
+	if err != nil {
+		return nil, err
+	}
 
 	bulk := ix.targetClient.Bulk()