Increase wait timeout
This commit is contained in:
parent
71e310f639
commit
603b3b31a6
|
@ -28,7 +28,7 @@ export abstract class AbstractIndexer <T extends IndexableDoc, DB> {
|
||||||
this.indexQueue = queue<QueueParam, Error>(async (task, cb) => {
|
this.indexQueue = queue<QueueParam, Error>(async (task, cb) => {
|
||||||
try {
|
try {
|
||||||
const { taskUid } = await this.indexSpecificElement(task.host, task.identifier)
|
const { taskUid } = await this.indexSpecificElement(task.host, task.identifier)
|
||||||
await client.index(this.indexName).waitForTask(taskUid)
|
await client.index(this.indexName).waitForTask(taskUid, { timeOutMs: 1000 * 60 * 5 }) // 5 minutes timeout
|
||||||
|
|
||||||
return cb()
|
return cb()
|
||||||
} catch (err) {
|
} catch (err) {
|
||||||
|
|
Loading…
Reference in New Issue