File tree Expand file tree Collapse file tree 1 file changed +5
-6
lines changed Expand file tree Collapse file tree 1 file changed +5
-6
lines changed Original file line number Diff line number Diff line change @@ -281,7 +281,6 @@ _.assignIn(util, {
281
281
apiVersion : '2006-03-01' ,
282
282
} ) ;
283
283
284
-
285
284
try {
286
285
const sourceParam = {
287
286
Bucket : sourceBucket ,
@@ -296,18 +295,18 @@ _.assignIn(util, {
296
295
297
296
await s3 . copyObject ( copyParam ) . promise ( ) ;
298
297
req . log . debug ( `s3FileTransfer: copyObject successfully: ${ sourceBucket } /${ sourceKey } ` ) ;
299
- // expect delteObject not block the request
300
- setTimeout ( async ( ) => {
298
+ // we don't want deleteObject to block the request as it's not critical operation
299
+ ( async ( ) => {
301
300
try {
302
301
await s3 . deleteObject ( sourceParam ) . promise ( ) ;
303
302
req . log . debug ( `s3FileTransfer: deleteObject successfully: ${ sourceBucket } /${ sourceKey } ` ) ;
304
303
} catch ( e ) {
305
- req . log . debug ( `s3FileTransfer: deleteObject failed: ${ sourceBucket } /${ sourceKey } : ${ e . message } ` ) ;
304
+ req . log . error ( `s3FileTransfer: deleteObject failed: ${ sourceBucket } /${ sourceKey } : ${ e . message } ` ) ;
306
305
}
307
- } ) ;
306
+ } ) ( ) ;
308
307
return { success : true } ;
309
308
} catch ( e ) {
310
- req . log . debug ( `s3FileTransfer: error: ${ e . message } ` ) ;
309
+ req . log . error ( `s3FileTransfer: error: ${ e . message } ` ) ;
311
310
throw e ;
312
311
}
313
312
} ,
You can’t perform that action at this time.
0 commit comments