Update generator_function/image_processor.py

generator_function/image_processor.py

@@ -14,9 +14,7 @@ logger = logging.getLogger(__name__)
 COL = get_collection()
 
 def _resolve_user_id() -> str:
-    return current_uid() or os.getenv("DEFAULT_USER_ID")
-
-uid = _resolve_user_id()
+    return current_uid() or os.getenv("DEFAULT_USER_ID", "anonymous")
 
 def process_zip_and_generate_images(
     zip_path: str,
@@ -30,6 +28,7 @@ def process_zip_and_generate_images(
     demo_mode: bool,
     existing_images: Optional[List[str]],
     blur: bool,
+    uid: str,
 ) -> List[str]:
     num_images = 1 if demo_mode else num_images
     try:
@@ -40,7 +39,7 @@ def process_zip_and_generate_images(
             image_files = [(os.path.basename(zip_path), zip_path)]
 
         results = process_image_files(
-            image_files, category, size, quality, user_prompt, sentiment, platform, num_images, blur
+            image_files, category, size, quality, user_prompt, sentiment, platform, num_images, blur, uid
         )
         all_urls = [url for entry in results for url in entry["urls"]]
         seen, deduped = set(), []
@@ -72,7 +71,7 @@ def get_valid_image_files(temp_dir: tempfile.TemporaryDirectory) -> List[Tuple[s
     return valid_files
 
 def process_image_files(image_files: List[Tuple[str, str]],category: str,size: str,
-    quality: str,user_prompt: str,sentiment: str,platform: str,num_images: int,blur: bool,
+    quality: str,user_prompt: str,sentiment: str,platform: str,num_images: int,blur: bool,uid: str,
 ) -> List[dict]:
     final_results: List[dict] = []
     with ThreadPoolExecutor(max_workers=5) as executor: