const processProduct = async (product) => {
try {
await api.enqueue(api.shopifyProduct.dailyStockRun, product,{
queue: { name: `daily-stock-${record.id}`, maxConcurrency: 5 }
});
} catch (error) {
logger.error({ error }, `Error processing product ${product.id}`);
}
};
await pMap(allProducts, processProduct, { concurrency: 20 });
const processProduct = async (product) => {
try {
await api.enqueue(api.shopifyProduct.dailyStockRun, product,{
queue: { name: `daily-stock-${record.id}`, maxConcurrency: 5 }
});
} catch (error) {
logger.error({ error }, `Error processing product ${product.id}`);
}
};
await pMap(allProducts, processProduct, { concurrency: 20 });