Pylint issue fix

Author: VishalS-Microsoft

src/backend/common/database/database_base.py

@@ -17,54 +17,54 @@ class DatabaseBase(ABC):
     @abstractmethod
     async def initialize_cosmos(self) -> None:
         """Initialize the cosmosdb client and create container if needed"""
-        pass # pragma: no cover
+        pass  # pragma: no cover
 
     @abstractmethod
     async def create_batch(self, user_id: str, batch_id: uuid.UUID) -> BatchRecord:
         """Create a new conversion batch"""
-        pass # pragma: no cover
+        pass  # pragma: no cover
 
     @abstractmethod
     async def get_file_logs(self, file_id: str) -> Dict:
         """Retrieve all logs for a file"""
-        pass # pragma: no cover
+        pass  # pragma: no cover
 
     @abstractmethod
     async def get_batch_from_id(self, batch_id: str) -> Dict:
         """Retrieve all logs for a file"""
-        pass # pragma: no cover
+        pass  # pragma: no cover
 
     @abstractmethod
     async def get_batch_files(self, batch_id: str) -> List[Dict]:
         """Retrieve all files for a batch"""
-        pass # pragma: no cover
+        pass  # pragma: no cover
 
     @abstractmethod
     async def delete_file_logs(self, file_id: str) -> None:
         """Delete all logs for a file"""
-        pass # pragma: no cover
+        pass  # pragma: no cover
 
     @abstractmethod
     async def get_user_batches(self, user_id: str) -> Dict:
         """Retrieve all batches for a user"""
-        pass # pragma: no cover
+        pass  # pragma: no cover
 
     @abstractmethod
     async def add_file(
         self, batch_id: uuid.UUID, file_id: uuid.UUID, file_name: str, storage_path: str
     ) -> FileRecord:
         """Add a file entry to the database"""
-        pass # pragma: no cover
+        pass  # pragma: no cover
 
     @abstractmethod
     async def get_batch(self, user_id: str, batch_id: str) -> Optional[Dict]:
         """Retrieve a batch and its associated files"""
-        pass # pragma: no cover
+        pass  # pragma: no cover
 
     @abstractmethod
     async def get_file(self, file_id: str) -> Optional[Dict]:
         """Retrieve a file entry along with its logs"""
-        pass # pragma: no cover
+        pass  # pragma: no cover
 
     @abstractmethod
     async def add_file_log(
@@ -77,39 +77,39 @@ async def add_file_log(
         author_role: AuthorRole,
     ) -> None:
         """Log a file status update"""
-        pass # pragma: no cover
+        pass  # pragma: no cover
 
     @abstractmethod
     async def update_file(self, file_record: FileRecord) -> None:
-        """update file record"""
-        pass # pragma: no cover
+        """Update file record"""
+        pass  # pragma: no cover
 
     @abstractmethod
     async def update_batch(self, batch_record: BatchRecord) -> BatchRecord:
         """Update a batch record"""
-        pass # pragma: no cover
+        pass  # pragma: no cover
 
     @abstractmethod
     async def delete_all(self, user_id: str) -> None:
         """Delete all batches, files, and logs for a user"""
-        pass # pragma: no cover
+        pass  # pragma: no cover
 
     @abstractmethod
     async def delete_batch(self, user_id: str, batch_id: str) -> None:
         """Delete a batch along with its files and logs"""
-        pass # pragma: no cover
+        pass  # pragma: no cover
 
     @abstractmethod
     async def delete_file(self, user_id: str, batch_id: str, file_id: str) -> None:
         """Delete a file and its logs, and update batch file count"""
-        pass # pragma: no cover
+        pass  # pragma: no cover
 
     @abstractmethod
     async def get_batch_history(self, user_id: str, batch_id: str) -> List[Dict]:
         """Retrieve all logs for a batch"""
-        pass # pragma: no cover
+        pass  # pragma: no cover
 
     @abstractmethod
     async def close(self) -> None:
         """Close database connection"""
-        pass # pragma: no cover
+        pass  # pragma: no cover

src/tests/backend/common/config/config_test.py

@@ -1,9 +1,6 @@
-import os
-import sys
 import pytest
- 
-sys.path.insert(0, os.path.abspath(os.path.join(os.path.dirname(__file__), '../../../..', 'backend')))
- 
+
+
 @pytest.fixture(autouse=True)
 def clear_env(monkeypatch):
     # Clear environment variables that might affect tests.
@@ -21,7 +18,8 @@ def clear_env(monkeypatch):
     ]
     for key in keys:
         monkeypatch.delenv(key, raising=False)
- 
+
+
 def test_config_initialization(monkeypatch):
     # Set the full configuration environment variables.
     monkeypatch.setenv("AZURE_TENANT_ID", "test-tenant-id")
@@ -34,11 +32,11 @@ def test_config_initialization(monkeypatch):
     monkeypatch.setenv("COSMOSDB_LOG_CONTAINER", "test-log-container")
     monkeypatch.setenv("AZURE_BLOB_CONTAINER_NAME", "test-blob-container-name")
     monkeypatch.setenv("AZURE_BLOB_ACCOUNT_NAME", "test-blob-account-name")
- 
+
     # Local import to avoid triggering circular imports during module collection.
     from common.config.config import Config
     config = Config()
- 
+
     assert config.azure_tenant_id == "test-tenant-id"
     assert config.azure_client_id == "test-client-id"
     assert config.azure_client_secret == "test-client-secret"
@@ -49,22 +47,21 @@ def test_config_initialization(monkeypatch):
     assert config.cosmosdb_log_container == "test-log-container"
     assert config.azure_blob_container_name == "test-blob-container-name"
     assert config.azure_blob_account_name == "test-blob-account-name"
- 
+
+
 def test_cosmosdb_config_initialization(monkeypatch):
     # Set only cosmosdb-related environment variables.
     monkeypatch.setenv("COSMOSDB_ENDPOINT", "test-cosmosdb-endpoint")
     monkeypatch.setenv("COSMOSDB_DATABASE", "test-database")
     monkeypatch.setenv("COSMOSDB_BATCH_CONTAINER", "test-batch-container")
     monkeypatch.setenv("COSMOSDB_FILE_CONTAINER", "test-file-container")
     monkeypatch.setenv("COSMOSDB_LOG_CONTAINER", "test-log-container")
- 
+
     from common.config.config import Config
     config = Config()
- 
+
     assert config.cosmosdb_endpoint == "test-cosmosdb-endpoint"
     assert config.cosmosdb_database == "test-database"
     assert config.cosmosdb_batch_container == "test-batch-container"
     assert config.cosmosdb_file_container == "test-file-container"
     assert config.cosmosdb_log_container == "test-log-container"
- 
- 

src/tests/backend/common/database/database_base_test.py

@@ -1,67 +1,66 @@
-import asyncio
 import uuid
-import pytest
-import os
-import sys
-from datetime import datetime
 from enum import Enum
- 
-sys.path.insert(0, os.path.abspath(os.path.join(os.path.dirname(__file__), '../../../../backend')))
- 
+
+
 from common.database.database_base import DatabaseBase
-from common.models.api import BatchRecord, FileRecord, ProcessStatus
- 
+from common.models.api import ProcessStatus
+
+import pytest
+
+
 # Allow instantiation of the abstract base class by clearing its abstract methods.
 DatabaseBase.__abstractmethods__ = set()
- 
+
+
 @pytest.fixture
 def db_instance():
     # Create a concrete implementation of DatabaseBase using async methods.
     class ConcreteDatabase(DatabaseBase):
         async def create_batch(self, user_id, batch_id):
             pass
- 
+
         async def get_file_logs(self, file_id):
             pass
- 
+
         async def get_batch_files(self, user_id, batch_id):
             pass
- 
+
         async def delete_file_logs(self, file_id):
             pass
- 
+
         async def get_user_batches(self, user_id):
             pass
- 
+
         async def add_file(self, batch_id, file_id, file_name, file_path):
             pass
- 
+
         async def get_batch(self, user_id, batch_id):
             pass
- 
+
         async def get_file(self, file_id):
             pass
- 
+
         async def log_file_status(self, file_id, status, description, log_type):
             pass
- 
+
         async def log_batch_status(self, batch_id, status, file_count):
             pass
- 
+
         async def delete_all(self, user_id):
             pass
- 
+
         async def delete_batch(self, user_id, batch_id):
             pass
- 
+
         async def delete_file(self, user_id, batch_id, file_id):
             pass
- 
+
         async def close(self):
             pass
- 
+
     return ConcreteDatabase()
- 
+
+
 def get_dummy_status():
     """
     Try to use a specific ProcessStatus value (e.g. PROCESSING).
@@ -76,76 +75,90 @@ def get_dummy_status():
         # If the enum is empty, create a dummy one.
         DummyStatus = Enum("DummyStatus", {"DUMMY": "dummy"})
         return DummyStatus.DUMMY
- 
+
+
 @pytest.mark.asyncio
 async def test_create_batch(db_instance):
     result = await db_instance.create_batch("user1", uuid.uuid4())
     # Since the method is implemented as pass, result is None.
     assert result is None
- 
+
+
 @pytest.mark.asyncio
 async def test_get_file_logs(db_instance):
     result = await db_instance.get_file_logs("file1")
     assert result is None
- 
+
+
 @pytest.mark.asyncio
 async def test_get_batch_files(db_instance):
     result = await db_instance.get_batch_files("user1", "batch1")
     assert result is None
- 
+
+
 @pytest.mark.asyncio
 async def test_delete_file_logs(db_instance):
     result = await db_instance.delete_file_logs("file1")
     assert result is None
- 
+
+
 @pytest.mark.asyncio
 async def test_get_user_batches(db_instance):
     result = await db_instance.get_user_batches("user1")
     assert result is None
- 
+
+
 @pytest.mark.asyncio
 async def test_add_file(db_instance):
     result = await db_instance.add_file(uuid.uuid4(), uuid.uuid4(), "test.txt", "/dummy/path")
     assert result is None
- 
+
+
 @pytest.mark.asyncio
 async def test_get_batch(db_instance):
     result = await db_instance.get_batch("user1", "batch1")
     assert result is None
- 
+
+
 @pytest.mark.asyncio
 async def test_get_file(db_instance):
     result = await db_instance.get_file("file1")
     assert result is None
- 
+
+
 @pytest.mark.asyncio
 async def test_log_file_status(db_instance):
     # Using ProcessStatus.COMPLETED as an example.
     result = await db_instance.log_file_status("file1", ProcessStatus.COMPLETED, "desc", "log_type")
     assert result is None
- 
+
+
 @pytest.mark.asyncio
 async def test_log_batch_status(db_instance):
     dummy_status = get_dummy_status()
     result = await db_instance.log_batch_status("batch1", dummy_status, 5)
     assert result is None
- 
+
+
 @pytest.mark.asyncio
 async def test_delete_all(db_instance):
     result = await db_instance.delete_all("user1")
     assert result is None
- 
+
+
 @pytest.mark.asyncio
 async def test_delete_batch(db_instance):
     result = await db_instance.delete_batch("user1", "batch1")
     assert result is None
- 
+
+
 @pytest.mark.asyncio
 async def test_delete_file(db_instance):
     result = await db_instance.delete_file("user1", "batch1", "file1")
     assert result is None
- 
+
+
 @pytest.mark.asyncio
 async def test_close(db_instance):
     result = await db_instance.close()
-    assert result is None
+    assert result is None