[Edit]

app.py

@@ -35,8 +35,17 @@ def run_pipeline():
         _id=pw.this._id,
         name=pw.this.name,
         price=pw.this.price,
+        description=pw.this.description,
         category=pw.this.category,
-        promo=pw.this.promoCopy
+        stock=pw.this.stock,
+        imageUrl=pw.this.imageUrl,
+        isNew=pw.this.isNew,
+        isActive=pw.this.isActive,
+        createdBy=pw.this.createdBy,
+        ratings=pw.this.ratings,
+        createdAt=pw.this.createdAt,
+        updatedAt=pw.this.updatedAt,
+        promoCopy=pw.this.promoCopy
     ).with_id_from(pw.this._id)
 
     def update_cache(key, row, time, is_addition):