diff --git a/app/services/stream_copy.js b/app/services/stream_copy.js index 8ee0930e..cbcca006 100644 --- a/app/services/stream_copy.js +++ b/app/services/stream_copy.js @@ -1,12 +1,9 @@ -const EventEmitter = require('events'); const PSQL = require('cartodb-psql'); const copyTo = require('pg-copy-streams').to; const copyFrom = require('pg-copy-streams').from; -module.exports = class StreamCopy extends EventEmitter { +module.exports = class StreamCopy { constructor (sql, userDbParams) { - super(); - this.pg = new PSQL(userDbParams); this.sql = sql; this.connectionClosedByClient = false;