chore: correctly rethrow errors

Cloudshelf · Dec 31, 2024 · a2c3455 · a2c3455
1 parent b2f7568
commit a2c3455
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 0 deletions.
diff --git a/src/modules/data-ingestion/product.job.utils.ts b/src/modules/data-ingestion/product.job.utils.ts
@@ -130,6 +130,7 @@ export class ProductJobUtils {
         } catch (err: any) {
             logs?.error(`Error in product consumer scheduler.`);
             logs?.error(`err`, err);
+            throw err;
         }
     }
 }
diff --git a/src/modules/shopify/webhooks/bulk.operation.finish.webhook.handler.ts b/src/modules/shopify/webhooks/bulk.operation.finish.webhook.handler.ts
@@ -52,12 +52,16 @@ export class BulkOperationFinishedWebhookHandler extends ShopifyWebhookHandler<u
         if (!bulkOp) {
             this.logger.log('bulkOpComplete webhook referenced unknown bulkOp');
             return;
+        } else {
+            this.logger.debug(`Loaded bulkop from database`, bulkOp);
         }
 
         const retailer = await this.retailerService.getByDomain(domain);
         if (!retailer) {
             this.logger.debug('Cannot get retailer for domain ' + domain);
             return;
+        } else {
+            this.logger.debug(`Loaded retailer from database`, retailer);
         }
 
         bulkOp = await this.bulkOperationService.updateFromShopify(retailer, bulkOp);