def process_csv()

in read_stall_retry/latency_per_time_gap.py [0:0]

• 15 lines of code
• 4 McCabe index (conditional complexity)

def process_csv(file: str, fs) -> pd.DataFrame:
    try:
        with fs.open(file, 'r') as f:
            df = pd.read_csv(f)
            if 'Overall Latency' not in df.columns:
                logger.warning(f"File {file} does not contain 'Overall Latency' column. Skipping file.")
                return pd.DataFrame()
            if not df.empty:
                df['Timestamp'] = pd.to_datetime(df['Timestamp'], unit='s')
                return df
            else:
                return pd.DataFrame()
    except Exception as e:
        logger.error(f"Error processing file {file}: {e}")
        return pd.DataFrame()