def process_csv_blob()

in read_stall_retry/max_latency_per_pod.py [0:0]

• 18 lines of code
• 5 McCabe index (conditional complexity)

def process_csv_blob(blob):
    """Processes a single CSV blob and finds the maximum latency."""
    try:
        content = blob.download_as_text()
        reader = csv.DictReader(io.StringIO(content))
        max_latency = 0
        max_latency_object = None
        for row in reader:
            try:
                latency = float(row.get("Overall Latency", 0))
                if latency > max_latency:
                    max_latency = latency
                    max_latency_object = row.get("Object Name")
            except ValueError:
                logger.warning(f"Invalid latency value in {blob.name}")
        return max_latency, max_latency_object, blob.name
    except Exception as e:
        logger.error(f"Error processing {blob.name}: {e}")
        return None, None, blob.name