Skip to content
Snippets Groups Projects
Commit 7632fd3d authored by Vytor Calixto's avatar Vytor Calixto :space_invader:
Browse files

[ci skip]Fixed using streams

parent cc7673e8
No related branches found
No related tags found
1 merge request!116Release v1.0.0
Pipeline #
......@@ -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);
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment