def process_logs()

in read_stall_retry/timeout_variation_in_pod.py [0:0]

• 10 lines of code
• 3 McCabe index (conditional complexity)

def process_logs(file_path: str, output_file: str):
    """Processes log files from local or GCS."""
    try:
        with fsspec.open(file_path, 'r') as infile:
            logs = infile.readlines()
            processed_data = extract_data(logs)
            write_to_csv(processed_data, output_file)
    except FileNotFoundError:
        logger.error(f"File not found: {file_path}")
    except Exception as e:
        logger.error(f"Error processing file {file_path}: {e}")