diff --git a/plugins/sqlite/writer.js b/plugins/sqlite/writer.js
index <HASH>..<HASH> 100644
--- a/plugins/sqlite/writer.js
+++ b/plugins/sqlite/writer.js
@@ -14,7 +14,7 @@ var Store = function(done, pluginMeta) {
   this.db.serialize(this.upsertTables);
 
   this.cache = [];
-  this.buffered = !(config.market && config.market.type === 'leech');
+  this.buffered = util.gekkoMode() === "importer";
 }
 
 Store.prototype.upsertTables = function() {
@@ -90,7 +90,7 @@ Store.prototype.writeCandles = function() {
 
 var processCandle = function(candle, done) {
   this.cache.push(candle);
-  if (this.buffered || this.cache.length > 1000) 
+  if (!this.buffered || this.cache.length > 1000) 
     this.writeCandles();
 
   done();
Buffered only when gekko mode is importing