Update app.py

app.py

@@ -15,10 +15,13 @@ os.environ["TRANSFORMERS_CACHE"] = "/app/cache"
 
 app = FastAPI()
 
-# Configure asynchronous logging with RotatingFileHandler to reduce I/O blocking
+# Configure asynchronous logging with RotatingFileHandler and StreamHandler
 logging.basicConfig(
     level=logging.INFO,
-    handlers=[logging.handlers.RotatingFileHandler("app.log", maxBytes=1000000, backupCount=1)]
+    handlers=[
+        logging.handlers.RotatingFileHandler("app.log", maxBytes=1000000, backupCount=1),
+        logging.StreamHandler()  # Added for console output
+    ]
 )
 logger = logging.getLogger(__name__)
 
@@ -31,7 +34,7 @@ MODEL_MAP = {
 }
 
 # List of terms to protect from translation
-PROTECTED_TERMS = ["2030 Aspirations"]
+PROTECTED_TERMS = ["2030 Aspirations", "Griffith", "SDG 2030"]
 
 # Cache for translators to avoid reloading models unnecessarily
 translators = {}
@@ -40,7 +43,6 @@ def get_translator(lang: str):
     """Load or retrieve cached translator for the given language."""
     if lang not in translators:
         logger.info(f"Loading model for {lang} from {MODEL_MAP[lang]}...")
-        # Optimize pipeline with max_length and num_beams for faster inference
         translators[lang] = pipeline(
             "translation",
             model=MODEL_MAP[lang],
@@ -73,7 +75,6 @@ def protect_terms(text: str, protected_terms: list) -> tuple[str, dict]:
     for i, term in enumerate(protected_terms):
         placeholder = f"__PROTECTED_{i}__"
         replacements[placeholder] = term
-        # Use regex for case-sensitive replacement in a single pass
         modified_text = re.sub(r'\b' + re.escape(term) + r'\b', placeholder, modified_text)
     if replacements:
         logger.debug(f"Protected terms replaced: {replacements}")
@@ -95,14 +96,13 @@ async def translate(text: str, source_lang_override: Optional[str] = None):
     if not text:
         raise HTTPException(status_code=400, detail="Text input is required.")
 
-    try.lytic
     try:
         # Determine source language
         if source_lang_override and source_lang_override in MODEL_MAP:
             source_lang = source_lang_override
             logger.debug(f"Source language overridden by user to: '{source_lang_override}'.")
         else:
-            source_lang = await asyncio.to_thread(detect_language, text)  # Run detection in a thread to avoid blocking
+            source_lang = await asyncio.to_thread(detect_language, text)
             logger.debug(f"Determined source language for translation: '{source_lang}'.")
 
         # If source language is English, return original text
@@ -138,4 +138,4 @@ async def translate(text: str, source_lang_override: Optional[str] = None):
         raise e
     except Exception as e:
         logger.error(f"An unexpected error occurred during processing: {str(e)}", exc_info=True)
-        raise HTTPException(statusinvestigate further
+        raise HTTPException(status_code=500, detail=f"Processing failed: {str(e)}")