fix: add dotenv loading, enrichment retry logic, and graceful error handling

- Load .env automatically via python-dotenv in config.py
- Retry Gemini calls up to 3 times with exponential backoff on empty responses
- Skip failed enrichments in CLI instead of crashing the full pipeline

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

cli.py

@@ -76,15 +76,18 @@ def enrich(cache_dir: str, enrichment_dir: str):
                 for c in story.get("credits", [])
                 if c.get("name")
             )
-            result = await _enrich(
-                title=story.get("name", ""),
-                description=description.strip(),
-                transcript=transcript.strip(),
-                cache_dir=enrichment_path,
-                story_uid=uid,
-                credits=credits_str,
-            )
-            click.echo(f"  [{i+1}/{len(files)}] {story.get('name', uid)} — {len(result.topics)} topics")
+            try:
+                result = await _enrich(
+                    title=story.get("name", ""),
+                    description=description.strip(),
+                    transcript=transcript.strip(),
+                    cache_dir=enrichment_path,
+                    story_uid=uid,
+                    credits=credits_str,
+                )
+                click.echo(f"  [{i+1}/{len(files)}] {story.get('name', uid)} — {len(result.topics)} topics")
+            except Exception as e:
+                click.echo(f"  [{i+1}/{len(files)}] FAIL {story.get('name', uid)}: {e}")
 
     asyncio.run(_run())
     click.echo("Enrichment complete.")

src/mediastorm/config.py

@@ -1,6 +1,10 @@
 import os
 from pathlib import Path
 
+from dotenv import load_dotenv
+
+load_dotenv()
+
 GEMINI_API_KEY = os.environ.get("GEMINI_API_KEY", "")
 HF_TOKEN = os.environ.get("HF_TOKEN", "")
 CHROMADB_PATH = Path(os.environ.get("CHROMADB_PATH", "./data/chromadb"))

src/mediastorm/enrich/enricher.py

@@ -89,15 +89,23 @@ async def enrich_story(
         themes=THEMES_LIST,
     )
 
+    import asyncio as _aio
+
     client = _get_client()
-    response = await client.aio.models.generate_content(
-        model=GEMINI_FLASH_MODEL,
-        contents=prompt,
-        config=GenerateContentConfig(
-            response_mime_type="application/json",
-            temperature=0.2,
-        ),
-    )
+    for attempt in range(3):
+        response = await client.aio.models.generate_content(
+            model=GEMINI_FLASH_MODEL,
+            contents=prompt,
+            config=GenerateContentConfig(
+                response_mime_type="application/json",
+                temperature=0.2,
+            ),
+        )
+        if response.text:
+            break
+        await _aio.sleep(2 ** attempt)
+    else:
+        raise ValueError(f"Gemini returned empty response after 3 attempts")
 
     raw = json.loads(response.text)
     enrichment = StoryEnrichment.model_validate(raw)