Fixed linter errors

Author: rishikeshdevsot

components/job-orchestration/job_orchestration/executor/compress/compression_task.py

@@ -446,7 +446,7 @@ def cleanup_temporary_files():
         )
         conversion_return_code = conversion_proc.wait()
     conversion_log_file.close()
-        
+
     try:
         if conversion_return_code != 0:
             logger.error(
@@ -458,14 +458,17 @@ def cleanup_temporary_files():
                 "error_message": f"Check logs in {conversion_log_path}",
             }
             log_file_contents(logger, conversion_log_path)
-            
+
             return CompressionTaskStatus.FAILED, worker_output
 
         # Start compression
         logger.debug("Compressing...")
         compression_successful = False
         proc = subprocess.Popen(
-            compression_cmd, stdout=subprocess.PIPE, stderr=compression_log_file, env=compression_env
+            compression_cmd,
+            stdout=subprocess.PIPE,
+            stderr=compression_log_file,
+            env=compression_env,
         )
 
         # Compute the total amount of data compressed

components/job-orchestration/job_orchestration/reducer/reducer.py

@@ -1,18 +1,19 @@
 #!/usr/bin/env python3
 
 import argparse
+import logging
 import os
 import subprocess
 import sys
-from concurrent.futures import ThreadPoolExecutor, as_completed
+from concurrent.futures import as_completed, ThreadPoolExecutor
 from pathlib import Path
 from typing import TextIO
-import logging
 
 from clp_py_utils.clp_config import ClpConfig
 from clp_py_utils.clp_logging import configure_logging, get_logger
 from clp_py_utils.core import read_yaml_config_file
 from pydantic import ValidationError
+
 from job_orchestration.executor.utils import log_file_contents
 
 logger = get_logger("reducer")
@@ -94,9 +95,7 @@ def main(argv: list[str]) -> int:
         f" Upsert Interval={parsed_args.upsert_interval}"
     )
     with ThreadPoolExecutor(max_workers=concurrency) as executor:
-        futures = {
-            executor.submit(reducers[i].communicate): i for i in range(concurrency)
-        }
+        futures = {executor.submit(reducers[i].communicate): i for i in range(concurrency)}
         for future in as_completed(futures):
             i = futures[future]
             future.result()

components/job-orchestration/job_orchestration/scheduler/query/query_scheduler.py

@@ -888,9 +888,7 @@ async def handle_finished_search_job(
         task_status = task_result.status
         if not task_status == QueryTaskStatus.SUCCEEDED:
             new_job_status = QueryJobStatus.FAILED
-            logger.error(
-                f"Search task job-{job_id}-task-{task_id} failed. "
-            )
+            logger.error(f"Search task job-{job_id}-task-{task_id} failed. ")
         else:
             job.num_archives_searched += 1
             logger.info(
@@ -979,9 +977,7 @@ async def handle_finished_stream_extraction_job(
         task_result = QueryTaskResult.model_validate(task_results[0])
         task_id = task_result.task_id
         if not QueryTaskStatus.SUCCEEDED == task_result.status:
-            logger.error(
-                f"Extraction task job-{job_id}-task-{task_id} failed. "
-            )
+            logger.error(f"Extraction task job-{job_id}-task-{task_id} failed. ")
             new_job_status = QueryJobStatus.FAILED
         else:
             logger.info(