style: Fix import sorting to pass isort CI checks

- Sort imports in AI/ML module files following PEP8 standards
- Fix import order in Cassandra database integration files
- Correct import sorting in enhanced parsers and schemas
- Sort imports in test files and orchestrator modules
- Ensure all files pass both Black formatting and isort checks

Resolves CI pipeline failure in Python 3.12 import validation

Author: tsrdatatech

src/ai/content_analyzer.py

@@ -8,22 +8,23 @@
 - Language detection and readability scoring
 """
 
+import logging
 import re
 from datetime import datetime
-from typing import Dict, List, Optional, Any
-import logging
+from typing import Any, Dict, List, Optional
 
 try:
-    from langchain_core.prompts import PromptTemplate
-    from langchain_core.output_parsers import PydanticOutputParser
-    from langchain_community.llms import FakeListLLM
     from langchain.schema import BaseMessage, HumanMessage
+    from langchain_community.llms import FakeListLLM
+    from langchain_core.output_parsers import PydanticOutputParser
+    from langchain_core.prompts import PromptTemplate
 
     LANGCHAIN_AVAILABLE = True
 except ImportError:
     LANGCHAIN_AVAILABLE = False
 
 from pydantic import BaseModel, Field
+
 from src.core.logger import logger
 from src.schemas.news import NewsArticle
 

src/database/__init__.py

@@ -4,8 +4,8 @@
 """
 
 from .cassandra_manager import (
-    CassandraManager,
     CassandraConfig,
+    CassandraManager,
     create_cassandra_manager,
 )
 

src/database/cassandra_manager.py

@@ -3,18 +3,19 @@
 Provides data persistence, deduplication, and seed management.
 """
 
+import asyncio
 import hashlib
+import json
 import uuid
+from dataclasses import dataclass
 from datetime import datetime
 from typing import Dict, List, Optional, Set
-from dataclasses import dataclass
-from cassandra.cluster import Cluster
+
+import aiohttp
 from cassandra.auth import PlainTextAuthProvider
-from cassandra.query import SimpleStatement
-import asyncio
+from cassandra.cluster import Cluster
 from cassandra.io.asyncorereactor import AsyncoreConnection
-import aiohttp
-import json
+from cassandra.query import SimpleStatement
 
 from src.core.logger import logger
 from src.schemas.news import NewsArticle

src/database/cassandra_parser_manager.py

@@ -3,13 +3,13 @@
 Provides persistent storage, deduplication, and seed management.
 """
 
-from typing import Dict, List, Optional
 from datetime import datetime
+from typing import Dict, List, Optional
 
+from src.core.logger import logger
 from src.core.parser_manager import ParserManager as BaseParserManager
-from src.database.cassandra_manager import CassandraManager, CassandraConfig
+from src.database.cassandra_manager import CassandraConfig, CassandraManager
 from src.schemas.news import NewsArticle
-from src.core.logger import logger
 
 
 class CassandraParserManager(BaseParserManager):

src/main.py

@@ -12,18 +12,10 @@
 # Add src to path for imports
 sys.path.insert(0, str(Path(__file__).parent))
 
-from crawlee.playwright_crawler import PlaywrightCrawler
-
-from src.core.logger import logger
-from src.core.parser_manager import ParserManager
-from src.core.parser_registry import create_parser_registry
-from src.core.proxy_config import create_proxy_configuration
-from src.core.seeds import resolve_seeds
-from src.routes import create_router
-
 from crawlee import ConcurrencySettings, Request
 from crawlee.crawlers import PlaywrightCrawler
 from crawlee.fingerprint_suite import DefaultFingerprintGenerator
+from crawlee.playwright_crawler import PlaywrightCrawler
 from dotenv import load_dotenv
 
 from core.logger import logger
@@ -32,6 +24,12 @@
 from core.proxy_config import create_proxy_configuration
 from core.seeds import resolve_seeds
 from routes import build_router
+from src.core.logger import logger
+from src.core.parser_manager import ParserManager
+from src.core.parser_registry import create_parser_registry
+from src.core.proxy_config import create_proxy_configuration
+from src.core.seeds import resolve_seeds
+from src.routes import create_router
 
 
 async def main() -> None:

src/orchestrator.py

@@ -6,18 +6,19 @@
 similar to AWS Step Functions + Batch but using pure K8s primitives.
 """
 
+import asyncio
+import json
+import logging
 import os
 import sys
-import json
 import time
-import asyncio
-import logging
 from datetime import datetime
-from typing import List, Dict, Optional, Set
 from pathlib import Path
+from typing import Dict, List, Optional, Set
 
 try:
-    from kubernetes import client, config as k8s_config
+    from kubernetes import client
+    from kubernetes import config as k8s_config
     from kubernetes.client.rest import ApiException
 except ImportError:
     print("Kubernetes client not installed. Install with: pip install kubernetes")

src/parsers/ai_enhanced_news.py

@@ -6,13 +6,14 @@
 """
 
 from typing import Any, Dict, Optional
+
 from playwright.async_api import Page
 
+from src.ai.content_analyzer import create_content_analyzer
 from src.core.base_parser import BaseParser
 from src.core.logger import logger
 from src.parsers.generic_news import GenericNewsParser
 from src.schemas.news import NewsArticle
-from src.ai.content_analyzer import create_content_analyzer
 
 
 class AIEnhancedNewsParser(GenericNewsParser):

src/schemas/news.py

@@ -3,7 +3,7 @@
 """
 
 from datetime import datetime
-from typing import Optional, List, Any, Dict
+from typing import Any, Dict, List, Optional
 
 from pydantic import BaseModel, Field, HttpUrl
 

tests/test_cassandra_integration.py

@@ -2,12 +2,13 @@
 Tests for Cassandra database integration.
 """
 
-import pytest
 import uuid
 from datetime import datetime
-from unittest.mock import Mock, AsyncMock, patch
+from unittest.mock import AsyncMock, Mock, patch
+
+import pytest
 
-from src.database.cassandra_manager import CassandraManager, CassandraConfig
+from src.database.cassandra_manager import CassandraConfig, CassandraManager
 from src.schemas.news import NewsArticle