Commit 0f91b3dc authored by A. Koch's avatar A. Koch

run queues through require

parent c082fc19
...@@ -14,7 +14,7 @@ class Metadata extends TinyEmitter { ...@@ -14,7 +14,7 @@ class Metadata extends TinyEmitter {
const _this = this const _this = this
this._queue = new Queue('conversions', config.conversions.redisURL) this._queue = new Queue('conversions', config.conversions.redisURL)
this._queue.process(parseInt(config.conversions.concurrency), path.join(__dirname, 'workers', 'convert.js')) this._queue.process(parseInt(config.conversions.concurrency), require('./workers/convert'))
app.post('/conversions', async (req, res) => { app.post('/conversions', async (req, res) => {
const jobId = ObjectUtil.uuid4() const jobId = ObjectUtil.uuid4()
......
...@@ -13,7 +13,7 @@ class Timecodes extends TinyEmitter { ...@@ -13,7 +13,7 @@ class Timecodes extends TinyEmitter {
super() super()
this._queue = new Queue('timecode', config.timecode.redisURL) this._queue = new Queue('timecode', config.timecode.redisURL)
this._queue.process(parseInt(config.timecode.concurrency), path.join(__dirname, 'workers', 'extract-ltc.js')) this._queue.process(parseInt(config.timecode.concurrency), require('./workers/extract-ltc'))
this._minio = new Minio.Client(config.assets.client) this._minio = new Minio.Client(config.assets.client)
...@@ -49,6 +49,7 @@ class Timecodes extends TinyEmitter { ...@@ -49,6 +49,7 @@ class Timecodes extends TinyEmitter {
source: job.data.source, source: job.data.source,
result: job.returnvalue, result: job.returnvalue,
failed: typeof job.failedReason !== 'undefined', failed: typeof job.failedReason !== 'undefined',
failedReason: job.failedReason,
attempts: job.attemptsMade, attempts: job.attemptsMade,
progress: job.progress, progress: job.progress,
delay: job.delay, delay: job.delay,
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment