lint issue fix

Author: AjitPadhi-Microsoft

src/ContentProcessor/src/tests/pipeline/entities/test_pipeline_data.py

@@ -2,7 +2,6 @@
 from unittest.mock import Mock
 from libs.pipeline.entities.pipeline_step_result import StepResult
 from libs.pipeline.entities.pipeline_status import PipelineStatus
-from libs.azure_helper.storage_blob import StorageBlobHelper
 
 
 def test_update_step():

src/ContentProcessor/src/tests/process_host/test_handler_type_loader.py

@@ -1,5 +1,4 @@
 import pytest
-from importlib import import_module
 from libs.pipeline.queue_handler_base import HandlerBase
 from libs.process_host.handler_type_loader import load
 

src/ContentProcessor/src/tests/utils/test_base64_util.py

@@ -1,4 +1,3 @@
-import pytest
 import base64
 from libs.utils.base64_util import is_base64_encoded
 

src/ContentProcessorAPI/app/libs/storage_blob/helper.py

@@ -93,15 +93,15 @@ def delete_blob_and_cleanup(self, blob_name, container_name=None):
 
     def delete_folder(self, folder_name, container_name=None):
         container_client = self._get_container_client(container_name)
-        
+
         # List all blobs inside the folder
         blobs_to_delete = container_client.list_blobs(name_starts_with=folder_name + "/")
 
         # Delete each blob
         for blob in blobs_to_delete:
             blob_client = container_client.get_blob_client(blob.name)
             blob_client.delete_blob()
-        
+
         blobs_to_delete = container_client.list_blobs()
         if not blobs_to_delete:
 
@@ -110,4 +110,4 @@ def delete_folder(self, folder_name, container_name=None):
 
             # Delete the (virtual) folder in the Container
             blob_client = container_client.get_blob_client(folder_name)
-            blob_client.delete_blob()
+            blob_client.delete_blob()

src/ContentProcessorAPI/app/routers/contentprocessor.py

@@ -492,6 +492,7 @@ async def get_original_file(
             file_stream, media_type=content_type_string, headers=headers
         )
 
+
 @router.delete(
     "/processed/{process_id}",
     response_model=ContentResultDelete,
@@ -502,9 +503,9 @@ async def get_original_file(
 )
 async def delete_processed_file(
     process_id: str, app_config: AppConfiguration = Depends(get_app_config)
-    ) -> ContentResultDelete:
+) -> ContentResultDelete:
     try:
-        deleted_file =  CosmosContentProcess(process_id=process_id).delete_processed_file(
+        deleted_file = CosmosContentProcess(process_id=process_id).delete_processed_file(
             connection_string=app_config.app_cosmos_connstr,
             database_name=app_config.app_cosmos_database,
             collection_name=app_config.app_cosmos_container_process,
@@ -518,4 +519,4 @@ async def delete_processed_file(
         status="Success" if deleted_file else "Failed",
         process_id=deleted_file.process_id if deleted_file else "",
         message="" if deleted_file else "This record no longer exists. Please refresh the page."
-    )
+    )

src/ContentProcessorAPI/app/routers/models/contentprocessor/content_process.py

@@ -189,7 +189,7 @@ def get_status_from_cosmos(
             return ContentProcess(**existing_process[0])
         else:
             return None
-    
+
     def delete_processed_file(
         self,
         connection_string: str,

src/ContentProcessorAPI/app/routers/models/contentprocessor/model.py

@@ -64,6 +64,7 @@ class ContentResultUpdate(BaseModel):
     process_id: str
     modified_result: dict
 
+
 class ContentResultDelete(BaseModel):
     process_id: str
     status: str

src/ContentProcessorAPI/app/tests/routers/test_schemavault.py

@@ -3,7 +3,6 @@
 from fastapi.testclient import TestClient
 from unittest.mock import MagicMock
 from app.routers.schemavault import router, get_schemas
-from app.routers.models.schmavault.model import SchemaVaultUnregisterRequest
 
 
 app = FastAPI()