Update app.py

app.py

@@ -12,6 +12,7 @@ import re
 PRINTIFY_BASE = "https://api.printify.com"
 DEFAULT_BASE_PRICE = 0.001
 GRID_FILENAME = "grid.png"
+MAX_VARIANTS_PER_PRODUCT = 100
 
 
 def _now() -> str:
@@ -708,46 +709,76 @@ def phase_b(currency: str) -> Generator[Tuple[str, str], None, None]:
             _log_catalog_variants(logs, product_info, limit=75)
             yield flush()
 
-            created = _create_product_all_variants_with_grid(
-                logs,
-                shop_id=shop_id,
-                blob=blob,
-                product_info=product_info,
-                upload=upload,
-            )
-            created_id = str(created.get("id") or "")
-            if not created_id:
-                raise RuntimeError("Created product response missing id.")
-            yield flush()
+            variants_all = product_info.get("variants") or []
+            if not isinstance(variants_all, list) or not variants_all:
+                _log(logs, f"PROVIDER_SKIP provider_id={provider_id} reason=no_variants_after_build")
+                yield flush()
+                continue
 
-            prod1 = _get_product(logs, shop_id, created_id)
-            yield flush()
+            total_variants = len(variants_all)
+            total_chunks = (total_variants + MAX_VARIANTS_PER_PRODUCT - 1) // MAX_VARIANTS_PER_PRODUCT
 
-            _log(
-                logs,
-                f"COMPARE_COUNTS provider={provider_id} "
-                f"catalog={len(product_info.get('variants') or [])} "
-                f"shop={len(prod1.get('variants') or [])}",
-            )
-            yield flush()
+            chunk_index = 0
+            offset = 0
+            while offset < total_variants:
+                chunk = variants_all[offset: offset + MAX_VARIANTS_PER_PRODUCT]
+                p_info_chunk = dict(product_info)
+                p_info_chunk["variants"] = chunk
 
-            upd = _update_prices_to_cost_plus_margin(logs, shop_id, created_id, prod1)
-            yield flush()
+                _log(
+                    logs,
+                    f"PROVIDER_CHUNK provider_id={provider_id} name={provider_name} "
+                    f"chunk_index={chunk_index} total_chunks={total_chunks} "
+                    f"offset={offset} size={len(chunk)} total_variants={total_variants}",
+                )
+                yield flush()
 
-            prod2 = _get_product(logs, shop_id, created_id)
-            yield flush()
+                created = _create_product_all_variants_with_grid(
+                    logs,
+                    shop_id=shop_id,
+                    blob=blob,
+                    product_info=p_info_chunk,
+                    upload=upload,
+                )
+                created_id = str(created.get("id") or "")
+                if not created_id:
+                    raise RuntimeError("Created product response missing id.")
+                yield flush()
 
-            provider_runs.append(
-                {
-                    "providerId": provider_id,
-                    "providerName": provider_name,
-                    "catalogVariantCount": len(product_info.get("variants") or []),
-                    "shopVariantCountAfterCreate": len(prod1.get("variants") or []),
-                    "shopVariantCountFinal": len(prod2.get("variants") or []),
-                    "productId": created_id,
-                    "priceUpdateResponse": upd,
-                }
-            )
+                prod1 = _get_product(logs, shop_id, created_id)
+                yield flush()
+
+                _log(
+                    logs,
+                    f"COMPARE_COUNTS provider={provider_id} chunk_index={chunk_index} "
+                    f"catalog_chunk={len(chunk)} "
+                    f"shop={len(prod1.get('variants') or [])}",
+                )
+                yield flush()
+
+                upd = _update_prices_to_cost_plus_margin(logs, shop_id, created_id, prod1)
+                yield flush()
+
+                prod2 = _get_product(logs, shop_id, created_id)
+                yield flush()
+
+                provider_runs.append(
+                    {
+                        "providerId": provider_id,
+                        "providerName": provider_name,
+                        "chunkIndex": chunk_index,
+                        "totalChunks": total_chunks,
+                        "catalogVariantCountTotal": total_variants,
+                        "catalogVariantCountChunk": len(chunk),
+                        "shopVariantCountAfterCreate": len(prod1.get("variants") or []),
+                        "shopVariantCountFinal": len(prod2.get("variants") or []),
+                        "productId": created_id,
+                        "priceUpdateResponse": upd,
+                    }
+                )
+
+                offset += MAX_VARIANTS_PER_PRODUCT
+                chunk_index += 1
 
         result["providerRuns"] = provider_runs
         _log(logs, "PHASE_B_DONE")