diff --git a/src/modules/data-ingestion/product.job.utils.ts b/src/modules/data-ingestion/product.job.utils.ts
index 68ad93e..dbc10e6 100644
--- 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
index 42b57f1..4ec97e1 100644
--- 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);