|
|
@@ -1,12 +1,12 @@
|
|
|
async = require "async"
|
|
|
Settings = require "settings-sharelatex"
|
|
|
-
|
|
|
+logger = require("logger-sharelatex")
|
|
|
queue = async.queue((task, cb)->
|
|
|
task(cb)
|
|
|
, Settings.parallelSqlQueryLimit)
|
|
|
|
|
|
queue.drain = ()->
|
|
|
- console.log('HI all items have been processed')
|
|
|
+ logger.debug('all items have been processed')
|
|
|
|
|
|
module.exports =
|
|
|
queue: queue
|