@@ -93,7 +93,6 @@ async function start() {
9393 requesterSecret = validateRequesterSecret ( requesterSecret ) ;
9494
9595 const bulkSize = parseInt ( IEXEC_BULK_SLICE_SIZE , 10 ) || 0 ;
96- const results = [ ] ;
9796
9897 // Process multiple protected data
9998 if ( bulkSize > 0 ) {
@@ -104,28 +103,24 @@ async function start() {
104103 IEXEC_IN ,
105104 appDeveloperSecret,
106105 requesterSecret,
107- } )
108- . then ( ( result ) => result )
109- . catch ( ( error ) => {
110- const datasetFilename =
111- process . env [ `IEXEC_DATASET_${ index } _FILENAME` ] ;
112- return {
113- index,
114- resultFileName : datasetFilename
115- ? `${ datasetFilename } .txt`
116- : `dataset-${ index } .txt` ,
117- response : {
118- status : 500 ,
119- message : `Failed to process protected-data ${ index } . Cause: ${ error . message } ` ,
120- } ,
121- } ;
122- } ) ;
106+ } ) . catch ( ( error ) => {
107+ const datasetFilename = process . env [ `IEXEC_DATASET_${ index } _FILENAME` ] ;
108+ return {
109+ index,
110+ resultFileName : datasetFilename
111+ ? `${ datasetFilename } .txt`
112+ : `dataset-${ index } .txt` ,
113+ response : {
114+ status : 500 ,
115+ message : `Failed to process protected-data ${ index } . Cause: ${ error . message } ` ,
116+ } ,
117+ } ;
118+ } ) ;
123119
124120 promises . push ( promise ) ;
125121 }
126122
127- const bulkResults = await Promise . all ( promises ) ;
128- results . push ( ...bulkResults ) ;
123+ const results = await Promise . all ( promises ) ;
129124
130125 // Write result.json for bulk processing
131126 const successCount = results . filter (
@@ -160,8 +155,6 @@ async function start() {
160155 requesterSecret,
161156 } ) ;
162157
163- results . push ( result ) ;
164-
165158 await writeTaskOutput (
166159 `${ workerEnv . IEXEC_OUT } /result.json` ,
167160 JSON . stringify ( result . response , null , 2 )
0 commit comments