Added simple logging

app.py

@@ -20,7 +20,6 @@ logging.basicConfig(
     format="%(asctime)s - %(name)s - %(levelname)s - %(message)s",
     handlers=[logging.StreamHandler()]
 )
-logger = logging.getLogger(__name__)
 
 # Initialize models
 embedding_model = None
@@ -33,27 +32,27 @@ async def lifespan(app: FastAPI):
     global embedding_model, summarization_model, nlp_model, db_service
     
     # Model initialization
-    logger.info("Initializing models...")
+    logging.info("Initializing models...")
     try:
         embedding_model = EmbeddingModel()
         summarization_model = SummarizationModel()
         nlp_model = NLPModel()
         db_service = DatabaseService()
-        logger.info("All models initialized successfully")
+        logging.info("All models initialized successfully")
     except Exception as e:
-        logger.error(f"Model initialization failed: {str(e)}")
+        logging.error(f"Model initialization failed: {str(e)}")
         raise
 
     yield
 
     # Cleanup
-    logger.info("Shutting down application...")
+    logging.info("Shutting down application...")
     if db_service:
         try:
             await db_service.close()
-            logger.info("Database connection closed successfully")
+            logging.info("Database connection closed successfully")
         except Exception as e:
-            logger.error(f"Error closing database connection: {str(e)}")
+            logging.error(f"Error closing database connection: {str(e)}")
 
 app = FastAPI(
     title="Kairos News API",
@@ -88,7 +87,7 @@ class JobStatus(BaseModel):
 @app.get("/")
 async def root(request: Request):
     """Root endpoint with API information"""
-    logger.info(f"Root access from {request.client.host}")
+    logging.info(f"Root access from {request.client.host}")
     return {
         "message": "Kairos News API is running",
         "endpoints": {
@@ -111,7 +110,7 @@ async def get_logs(log_type: str = None):
 @app.exception_handler(404)
 async def not_found_exception_handler(request: Request, exc: HTTPException):
     """Custom 404 handler"""
-    logger.warning(f"404 Not Found: {request.url}")
+    logging.warning(f"404 Not Found: {request.url}")
     return JSONResponse(
         status_code=404,
         content={
@@ -128,7 +127,7 @@ async def not_found_exception_handler(request: Request, exc: HTTPException):
 @app.post("/index", response_model=JobStatus)
 async def create_job(request: PostRequest, background_tasks: BackgroundTasks):
     job_id = str(uuid.uuid4())
-    logger.info(f"Creating new job {job_id} with request: {request.dict()}")
+    logging.info(f"Creating new job {job_id} with request: {request.dict()}")
 
     jobs_db[job_id] = {
         "id": job_id,
@@ -149,17 +148,17 @@ async def create_job(request: PostRequest, background_tasks: BackgroundTasks):
         db_service
     )
     
-    logger.info(f"Job {job_id} created and processing started")
+    logging.info(f"Job {job_id} created and processing started")
     return jobs_db[job_id]
 
 @app.get("/loading", response_model=JobStatus)
 async def get_job_status(id: str):
-    logger.info(f"Checking status for job {id}")
+    logging.info(f"Checking status for job {id}")
     if id not in jobs_db:
-        logger.warning(f"Job {id} not found")
+        logging.warning(f"Job {id} not found")
         raise HTTPException(status_code=404, detail="Job not found")
     
-    logger.info(f"Returning status for job {id}: {jobs_db[id]['status']}")
+    logging.info(f"Returning status for job {id}: {jobs_db[id]['status']}")
     return jobs_db[id]
 
 async def process_job(
@@ -171,7 +170,7 @@ async def process_job(
     db_service: DatabaseService
 ):
     try:
-        logger.info(f"Starting processing for job {job_id}")
+        logging.info(f"Starting processing for job {job_id}")
         
         processor = QueryProcessor(
             embedding_model=embedding_model,
@@ -180,7 +179,7 @@ async def process_job(
             db_service=db_service
         )
         
-        logger.debug(f"Processing query: {request.query}")
+        logging.debug(f"Processing query: {request.query}")
         result = await processor.process(
             query=request.query,
             topic=request.topic,
@@ -193,13 +192,13 @@ async def process_job(
             "completed_at": datetime.now(),
             "result": result if result else {"message": "No results found"}
         })
-        logger.info(f"Job {job_id} completed successfully")
+        logging.info(f"Job {job_id} completed successfully")
         
     except Exception as e:
-        logger.error(f"Error processing job {job_id}: {str(e)}", exc_info=True)
+        logging.error(f"Error processing job {job_id}: {str(e)}", exc_info=True)
         jobs_db[job_id].update({
             "status": "failed",
             "completed_at": datetime.now(),
             "result": {"error": str(e)}
         })
-        logger.info(f"Job {job_id} marked as failed")
+        logging.info(f"Job {job_id} marked as failed")