patch.diff

<<<<<<< SEARCH
        # Use StringIO to build CSV content asynchronously
        import io

        output = io.StringIO()
        writer = csv.DictWriter(output, fieldnames=self.data[0].keys())
        writer.writeheader()
        for row in self.data:
            writer.writerow(row)

        # Write the CSV content to file
        async with aiofiles.open(expanded_path, "w") as f:
            await f.write(output.getvalue())
=======
        import asyncio

        def _write_csv(path: str, data: list[dict]):
            with open(path, "w", newline="") as f:
                writer = csv.DictWriter(f, fieldnames=data[0].keys())
                writer.writeheader()
                writer.writerows(data)

        # Offload CPU-intensive task to thread to prevent blocking event loop and avoid large memory allocations
        await asyncio.to_thread(_write_csv, expanded_path, self.data)
>>>>>>> REPLACE