Reformat examples (#2186)

- **Reformatted examples and scripts**

Author: NirantK

examples/gdrive_append_example.py

@@ -53,7 +53,7 @@ def append_to_existing_dataset():
     print("Existing records:")
     for i, record in enumerate(dataset):
         print(
-            f"  {i+1}. {record['question'] if isinstance(record, dict) else record.question}"
+            f"  {i + 1}. {record['question'] if isinstance(record, dict) else record.question}"
         )
 
     # Add new records
@@ -88,7 +88,7 @@ def append_to_existing_dataset():
     print("\nAll records in dataset:")
     for i, record in enumerate(dataset):
         print(
-            f"  {i+1}. {record['question'] if isinstance(record, dict) else record.question} -> {record['answer'] if isinstance(record, dict) else record.answer}"
+            f"  {i + 1}. {record['question'] if isinstance(record, dict) else record.question} -> {record['answer'] if isinstance(record, dict) else record.answer}"
         )
 
     return dataset

examples/gdrive_backend_example.py

@@ -22,7 +22,6 @@
 For detailed setup instructions, see the documentation.
 """
 
-import os
 from pydantic import BaseModel
 
 from ragas.experimental.dataset import Dataset
@@ -105,7 +104,7 @@ def example_usage():
     # Access individual records
     for i, record in enumerate(dataset):
         print(
-            f"Record {i+1}: {record['question'] if isinstance(record, dict) else record.question} -> {record['answer'] if isinstance(record, dict) else record.answer} (Score: {record['score'] if isinstance(record, dict) else record.score})"
+            f"Record {i + 1}: {record['question'] if isinstance(record, dict) else record.question} -> {record['answer'] if isinstance(record, dict) else record.answer} (Score: {record['score'] if isinstance(record, dict) else record.score})"
         )
 
     # List all datasets in the backend

examples/prompt_evals/evals.py

@@ -18,7 +18,6 @@ def my_metric(prediction: str, actual: str):
 
 @experiment()
 async def run_experiment(row):
-
     response = run_prompt(row["text"])
     score = my_metric.score(prediction=response, actual=row["label"])
 
@@ -72,7 +71,6 @@ async def main():
 
 
 if __name__ == "__main__":
-
     import asyncio
 
     asyncio.run(main())

examples/rag_eval/evals.py

@@ -12,7 +12,6 @@
 
 
 def load_dataset():
-
     dataset = Dataset(
         name="test_dataset",
         backend="local/csv",

examples/rag_eval/rag.py

@@ -1,4 +1,4 @@
-from typing import List, Dict, Any, Optional, Tuple
+from typing import List, Dict, Any, Optional
 from openai import OpenAI
 import json
 import os
@@ -456,7 +456,6 @@ def default_rag_client(llm_client, logdir: str = "logs") -> ExampleRAG:
 
 
 if __name__ == "__main__":
-
     try:
         api_key = os.environ["OPENAI_API_KEY"]
     except KeyError:

examples/workflow_eval/evals.py

@@ -12,7 +12,6 @@
 
 
 def load_dataset():
-
     dataset_dict = [
         {
             "email": "Hi, I'm getting error code XYZ-123 when using version 2.1.4 of your software. Please help!",

examples/workflow_eval/workflow.py

@@ -178,7 +178,7 @@ def extract(self, email_content: str, category: str) -> Dict[str, Optional[str]]
             )
             return result
 
-        except Exception as e:
+        except Exception:
             return {}
 
     def _get_bug_extraction_prompt(self, email_content: str) -> str:
@@ -362,7 +362,7 @@ def classify_email(self, email_content: str) -> str:
             return category
 
         except Exception as e:
-            print(f"   ⚠️ Classification failed, using fallback: Bug Report")
+            print("   ⚠️ Classification failed, using fallback: Bug Report")
             self.traces.append(
                 TraceEvent(
                     event_type="error",
@@ -491,7 +491,7 @@ def generate_response(self, category: str, extracted_info: Dict[str, Any]) -> st
             return response_text
 
         except Exception as e:
-            print(f"   ⚠️ Response generation failed, using fallback")
+            print("   ⚠️ Response generation failed, using fallback")
             self.traces.append(
                 TraceEvent(
                     event_type="error",
@@ -571,7 +571,7 @@ def process_email(
                 ),
             }
 
-            print(f"✅ Workflow completed successfully")
+            print("✅ Workflow completed successfully")
             print(f"📋 Traces saved to: logs/run_{run_id}_*.json")
 
             self.traces.append(

scripts/process_experimental_notebooks.py

@@ -7,9 +7,7 @@
 import os
 import sys
 import subprocess
-import shutil
 from pathlib import Path
-import glob
 
 # Path configurations
 RAGAS_ROOT = Path(__file__).parent.parent