diff --git a/src/monitor_utils/database.py b/src/monitor_utils/database.py index 724b082..66f07d6 100644 --- a/src/monitor_utils/database.py +++ b/src/monitor_utils/database.py @@ -92,7 +92,7 @@ async def add_products_to_database( now = datetime.now(timezone.utc) price_key = str(int(now.timestamp() * 1000)) for product, doc_id in zip(products, doc_ids): - document = convert_product_to_mongo(product, category_identifier) + document = convert_product_to_mongo(product) document["_id"] = doc_id old_price = existing_prices.get(doc_id) new_price = document.get("currentPrice")