Add error logging in azure queue push

clearlydefined · Jan 16, 2025 · c9cfd27 · c9cfd27
1 parent 1692af1
commit c9cfd27
Showing 1 changed file with 10 additions and 4 deletions.
diff --git 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
+          }
         })
       )
     )