diff --git a/scripts/import_markdown.py b/scripts/import_markdown.py
index 5640077..718d96c 100644
--- a/scripts/import_markdown.py
+++ b/scripts/import_markdown.py
@@ -20,13 +20,19 @@ def iter_md(root: str):
 
 def main():
     load_dotenv()
+    
+    # FIX: Default Prefix aus Environment holen, sonst Fallback auf "mindnet"
+    default_prefix = os.getenv("COLLECTION_PREFIX", "mindnet")
+
     ap = argparse.ArgumentParser()
     ap.add_argument("--vault", required=True)
     ap.add_argument("--apply", action="store_true")
     ap.add_argument("--purge-before-upsert", action="store_true")
     ap.add_argument("--force-replace", action="store_true")
-    ap.add_argument("--prefix", default="mindnet")
-    # Weitere Argumente (compat) können hier hinzugefügt werden, wenn nötig
+    
+    # Hier nutzen wir jetzt die Variable
+    ap.add_argument("--prefix", default=default_prefix)
+    
     args = ap.parse_args()
 
     print(f"Init IngestionService (Prefix: {args.prefix})...")
@@ -39,7 +45,6 @@ def main():
     errors = 0
     
     for f in files:
-        # Hier rufen wir den neuen Service
         res = service.process_file(
             file_path=f,
             vault_root=os.path.abspath(args.vault),
@@ -48,7 +53,6 @@ def main():
             purge_before=args.purge_before_upsert
         )
         
-        # Output nur wenn relevant (nicht skipped/unchanged)
         if res.get("status") not in ["skipped", "unchanged"]:
             print(json.dumps(res, ensure_ascii=False))
             processed += 1