From 7632fd3d948a09f0903cb8bf8e4f21d762a9bfeb Mon Sep 17 00:00:00 2001
From: Vytor Calixto <vytorcalixto@gmail.com>
Date: Wed, 28 Jun 2017 10:43:03 -0300
Subject: [PATCH] [ci skip]Fixed using streams
---
src/libs/jobs/download.js | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git a/src/libs/jobs/download.js b/src/libs/jobs/download.js
index 14eb05b5..829d3460 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);
--
GitLab