diff --git a/src/libs/jobs/download.js b/src/libs/jobs/download.js
index 14eb05b5024164a6c6758f2487ecb77084968a87..829d346088426f393095ad09c2a44df2c71e8fe4 100644
--- a/src/libs/jobs/download.js
+++ b/src/libs/jobs/download.js
@@ -10,14 +10,15 @@ module.exports = function(agenda) {
         let sql = job.attrs.data.sql;
         execQuery(sql.text, sql.values).then((result) => {
             log.debug('Got results');
-            log.debug(typeof result);
 
             let reader = new Readable();
             reader._read = function noop(){};
-            reader.push(result);
+            reader.push(JSON.stringify(result));
             let writer = fs.createWriteStream('out.csv');
 
             reader.pipe(jsonexport()).pipe(writer);
+            log.debug('Wrote file');
+            done();
         }, (err) => {
             log.error('Error getting data from database!');
             log.error(err);