diff --git a/ghcrawler/providers/queuing/storageQueue.js b/ghcrawler/providers/queuing/storageQueue.js index b93e60d..982ff3f 100644 --- a/ghcrawler/providers/queuing/storageQueue.js +++ b/ghcrawler/providers/queuing/storageQueue.js @@ -37,10 +37,16 @@ class StorageQueue { return Promise.all( requests.map( qlimit(this.options.parallelPush || 1)(async request => { - const body = JSON.stringify(request) - const queueMessageResult = await this.queueClient.sendMessage(body) - this._log('Queued', request) - return this._buildMessageReceipt(queueMessageResult, request) + try { + const body = JSON.stringify(request) + const queueMessageResult = await this.queueClient.sendMessage(body) + this._log('Queued', request) + return this._buildMessageReceipt(queueMessageResult, request) + } catch (error) { + this.logger.error(`Failed to push message: ${error.message}`) + this.logger.error(`Request: ${JSON.stringify(request, null, 2)}`) + throw error + } }) ) )