copy from: remove client dependecy
This commit is contained in:
parent
327aaf3450
commit
925115e8c1
@ -109,7 +109,7 @@ function handleCopyFrom (logger) {
|
|||||||
const metrics = new StreamCopyMetrics(logger, 'copyfrom', sql, user, isGzip);
|
const metrics = new StreamCopyMetrics(logger, 'copyfrom', sql, user, isGzip);
|
||||||
|
|
||||||
streamCopy.from(
|
streamCopy.from(
|
||||||
function (err, pgstream, copyFromStream, client, done) {
|
function (err, pgstream, copyFromStream, done) {
|
||||||
if (err) {
|
if (err) {
|
||||||
return next(err);
|
return next(err);
|
||||||
}
|
}
|
||||||
|
@ -65,7 +65,7 @@ module.exports = class StreamCopy {
|
|||||||
client.connection.sendCopyFail('CARTO SQL API: Connection closed by client');
|
client.connection.sendCopyFail('CARTO SQL API: Connection closed by client');
|
||||||
});
|
});
|
||||||
|
|
||||||
cb(null, pgstream, copyFromStream, client, done);
|
cb(null, pgstream, copyFromStream, done);
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user