|
@@ -220,9 +220,15 @@ module.exports = class GcsPersistor extends AbstractPersistor {
|
|
|
.bucket(bucketName)
|
|
.bucket(bucketName)
|
|
|
.getFiles({ directory: key })
|
|
.getFiles({ directory: key })
|
|
|
|
|
|
|
|
- await asyncPool(this.settings.deleteConcurrency, files, async (file) => {
|
|
|
|
|
- await this.deleteObject(bucketName, file.name)
|
|
|
|
|
- })
|
|
|
|
|
|
|
+ if (Array.isArray(files) && files.length > 0) {
|
|
|
|
|
+ await asyncPool(
|
|
|
|
|
+ this.settings.deleteConcurrency,
|
|
|
|
|
+ files,
|
|
|
|
|
+ async (file) => {
|
|
|
|
|
+ await this.deleteObject(bucketName, file.name)
|
|
|
|
|
+ }
|
|
|
|
|
+ )
|
|
|
|
|
+ }
|
|
|
} catch (err) {
|
|
} catch (err) {
|
|
|
const error = PersistorHelper.wrapError(
|
|
const error = PersistorHelper.wrapError(
|
|
|
err,
|
|
err,
|