File tree Expand file tree Collapse file tree 1 file changed +6
-11
lines changed
packages/cubejs-query-orchestrator/src/orchestrator Expand file tree Collapse file tree 1 file changed +6
-11
lines changed Original file line number Diff line number Diff line change @@ -273,25 +273,20 @@ export class QueryCache {
273
273
}
274
274
275
275
private async csvQuery ( client , q ) {
276
- const tableData = await client . stream ( q . query , q . values , q ) ;
276
+ const tableData = await client . downloadQueryResults ( q . query , q . values , q ) ;
277
277
const headers = tableData . types . map ( c => c . name ) ;
278
278
const writer = csvWriter ( {
279
279
headers,
280
280
sendHeaders : false ,
281
281
} ) ;
282
- const errors = [ ] ;
283
- const csvPipeline = await pipeline ( tableData . rowStream , writer , ( err ) => {
284
- if ( err ) {
285
- errors . push ( err ) ;
286
- }
287
- } ) ;
288
- const lines = await streamToArray ( csvPipeline ) ;
282
+ tableData . rows . forEach (
283
+ row => writer . write ( row )
284
+ ) ;
285
+ writer . end ( ) ;
286
+ const lines = await streamToArray ( writer ) ;
289
287
if ( tableData . release ) {
290
288
await tableData . release ( ) ;
291
289
}
292
- if ( errors . length > 0 ) {
293
- throw new Error ( `Lambda query errors ${ errors . join ( ', ' ) } ` ) ;
294
- }
295
290
const rowCount = lines . length ;
296
291
const csvRows = lines . join ( '' ) ;
297
292
return {
You can’t perform that action at this time.
0 commit comments