migrating to typescript
This commit is contained in:
parent
6a6203b615
commit
d750aef2d7
|
@ -127,11 +127,12 @@ async function pipeData(conversion: Conversion, dataLoaderPath: string, options:
|
||||||
Total rows to insert into "${ conversion._schema }"."${ signal.tableName }": ${ signal.totalRowsToInsert }`;
|
Total rows to insert into "${ conversion._schema }"."${ signal.tableName }": ${ signal.totalRowsToInsert }`;
|
||||||
|
|
||||||
log(conversion, msg);
|
log(conversion, msg);
|
||||||
} else {
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
killProcess(loaderProcess.pid, conversion);
|
killProcess(loaderProcess.pid, conversion);
|
||||||
conversion._processedChunks += chunksToLoad.length;
|
conversion._processedChunks += chunksToLoad.length;
|
||||||
return pipeData(conversion, dataLoaderPath, options);
|
return pipeData(conversion, dataLoaderPath, options);
|
||||||
}
|
|
||||||
});
|
});
|
||||||
|
|
||||||
loaderProcess.send(new MessageToDataLoader(conversion._config, chunksToLoad));
|
loaderProcess.send(new MessageToDataLoader(conversion._config, chunksToLoad));
|
||||||
|
|
Loading…
Reference in a new issue