|
@@ -14,7 +14,7 @@ module.exports = ResourceWriter =
|
|
|
jobs = for resource in resources
|
|
jobs = for resource in resources
|
|
|
do (resource) =>
|
|
do (resource) =>
|
|
|
(callback) => @_writeResourceToDisk(project_id, resource, basePath, callback)
|
|
(callback) => @_writeResourceToDisk(project_id, resource, basePath, callback)
|
|
|
- async.series jobs, callback
|
|
|
|
|
|
|
+ async.parallelLimit jobs, 5, callback
|
|
|
|
|
|
|
|
_removeExtraneousFiles: (resources, basePath, _callback = (error) ->) ->
|
|
_removeExtraneousFiles: (resources, basePath, _callback = (error) ->) ->
|
|
|
timer = new Metrics.Timer("unlink-output-files")
|
|
timer = new Metrics.Timer("unlink-output-files")
|