diff --git a/src/api/reddit.js b/src/api/reddit.js
index 071bdc5..1f3752d 100644
--- a/src/api/reddit.js
+++ b/src/api/reddit.js
@@ -17,7 +17,6 @@ export default class RedditAPI {
       const tracks = await this.getTracks(id, {limit: 1});
       return convertChannel(id, tracks.list[0].cover);
     } catch (err) {
-      console.error(err);
       return null;
     }
   }
diff --git a/src/server/jobs/update-schema.js b/src/server/jobs/update-schema.js
index 6a51b84..eeced8b 100644
--- a/src/server/jobs/update-schema.js
+++ b/src/server/jobs/update-schema.js
@@ -2,7 +2,11 @@ export default async function updateSchema(storage) {
   const db = await storage.getDb();
   const collection = db.collection('channels');
 
-  await collection.dropIndex('TextIndex');
+  try {
+    await collection.dropIndex('TextIndex');
+  } catch (err) {
+    await db.createCollection('channels');
+  }
 
   return collection.createIndex(
     {name: 'text', description: 'text', tags: 'text'},
diff --git a/test/server/storage_test.js b/test/server/storage_test.js
index 2d8c276..8f780ec 100644
--- a/test/server/storage_test.js
+++ b/test/server/storage_test.js
@@ -1,10 +1,15 @@
 import mongo from 'mongodb';
+import updateSchema from '../../src/server/jobs/update-schema';
 import Storage from '../../src/server/storage';
 import {MONGO_URI_TEST} from '../../src/config';
 
 describe('Storage @database', () => {
   const storage = new Storage(MONGO_URI_TEST);
 
+  before(async () => {
+    await updateSchema(storage);
+  });
+
   beforeEach((done) => {
     mongo.connect(MONGO_URI_TEST, (err, db) => {
       db.collection('channels').deleteMany({}, done);