1
- import { mapLimit } from 'async/mapLimit' ;
1
+ import mapLimit from 'async/mapLimit' ;
2
2
import { PlatformApiRestClient } from './PlatformApiRestClient' ;
3
3
4
4
async function sleep ( amount ) { await new Promise ( r => setTimeout ( r , amount ) ) ; }
@@ -147,10 +147,10 @@ export class PlatformApiLogicClient extends PlatformApiRestClient {
147
147
const workspaces = await this . fetchWorkspaceList ( { } ) ;
148
148
if ( ! workspaceId ) {
149
149
const nonFlatFlows = await mapLimit ( workspaces , realSplitFactor ,
150
- async workspace => this . fetchAllFlowsForWorkspace ( {
151
- parallelCalls : parallelizationPerTask ,
152
- workspaceId : workspace . workspaceId ,
153
- } ) ) ;
150
+ async workspace => this . fetchAllFlowsForWorkspace ( {
151
+ parallelCalls : parallelizationPerTask ,
152
+ workspaceId : workspace . workspaceId ,
153
+ } ) ) ;
154
154
flows = nonFlatFlows . flat ( ) ;
155
155
} else {
156
156
flows = await this . fetchAllFlowsForWorkspace ( {
@@ -508,7 +508,7 @@ export class PlatformApiLogicClient extends PlatformApiRestClient {
508
508
method : 'GET' ,
509
509
url : `/data-samples/${ sampleId } ` ,
510
510
} ) ;
511
- } catch ( e ) {
511
+ } catch ( e : any ) {
512
512
throw new Error ( `Can't extract data sample with id: ${ sampleId } . Error: ${ e . message } ` ) ;
513
513
}
514
514
const sample = sampleRequest . data . attributes ;
@@ -521,7 +521,7 @@ export class PlatformApiLogicClient extends PlatformApiRestClient {
521
521
/* eslint-disable-next-line no-param-reassign */
522
522
soFar [ sample . sampleId ] = sample . sample ;
523
523
return soFar ;
524
- } , { } ) ;
524
+ } , { } ) ;
525
525
flow . attributes . graph . nodes
526
526
. filter ( node => node . selected_data_samples )
527
527
. forEach ( ( node ) => {
0 commit comments