ruler docs

docs/docs.json

@@ -56,21 +56,17 @@
         "pages": [
           "fundamentals/training-loop",
           "fundamentals/art-client",
-          "fundamentals/art-backend"
+          "fundamentals/art-backend",
+          "fundamentals/ruler"
         ]
       },
       {
         "group": "Tutorials",
-        "pages": [
-          "tutorials/summarizer"
-        ]
+        "pages": ["tutorials/summarizer"]
       },
       {
         "group": "Resources",
-        "pages": [
-          "resources/models",
-          "resources/glossary"
-        ]
+        "pages": ["resources/models", "resources/glossary"]
       }
     ]
   },
@@ -81,4 +77,4 @@
     "bluesky": "https://bsky.app/profile/openpipe.bsky.social",
     "github": "https://github.com/openpipe/ART"
   }
-}
+}

docs/fundamentals/ruler.mdx

@@ -0,0 +1,279 @@
+---
+title: "RULER"
+icon: "ruler"
+description: "Learn how to use RULER to automatically reward your agents."
+---
+
+# 📏RULER: Relative Universal LLM-Elicited Rewards
+
+RULER (Relative Universal LLM-Elicited Rewards) is a general-purpose reward function that uses an LLM-as-judge to rank multiple agent trajectories. It requires no labeled data, expert feedback, or hand-crafted reward functions, yet reliably improves agent performance.
+
+<div align="center">
+  <img src="/images/ruler-results.png" alt="RULER Performance Results" style={{maxWidth: "100%", height: "auto"}} />
+  <p><em>RULER performance across multiple tasks at launch. In 3 out of 4 tasks, models trained with RULER slightly outperform those trained with hand-crafted reward functions. See the full <a href="https://openpipe.ai/blog/ruler">launch announcement</a> for details.</em></p>
+</div>
+
+## Key Benefits
+
+- **No labeled data required**: RULER works by comparing trajectories against each other
+- **General-purpose**: Can be applied to a wide variety of RL tasks without modification
+- **Fast development**: Can reduce implementation time by 2-3x compared to hand-crafted rewards
+- **Strong performance**: Often matches or exceeds hand-crafted reward functions
+
+## How RULER Works
+
+RULER leverages two key insights:
+
+1. **Relative scoring is easier than absolute scoring**: It's easier for an LLM to rank several solutions relative to each other than to score them in isolation
+2. **GRPO only needs relative scores**: Since GRPO normalizes scores within each group, only the relative rankings matter, not absolute values
+
+The process:
+1. Generate N trajectories for a given scenario
+2. Pass all N trajectories to RULER
+3. RULER deduplicates common prefixes (e.g., identical system messages)
+4. An LLM judge scores each trajectory from 0 to 1 based on goal achievement
+5. These scores are used directly as rewards in GRPO training
+
+## Basic Usage
+
+```python
+import art
+from art.rewards import ruler_score_group
+
+# Create a TrajectoryGroup from your trajectories
+group = art.TrajectoryGroup([...])  # List of art.Trajectory objects
+
+# Use RULER to score them
+judged_group = await ruler_score_group(
+    group,
+    {"model": "openai/o3"},
+    debug=True  # Shows the judge's reasoning
+)
+
+# Access the scores
+if judged_group:  # Check if judging succeeded
+    for traj in judged_group.trajectories:
+        print(f"Reward: {traj.reward}")
+        print(f"RULER explanation: {traj.logs[-1]}")
+```
+
+## Complete Example: Joke Generation
+
+Here's a toy example showing how RULER ranks different quality trajectories:
+
+```python
+import asyncio
+import art
+from art.rewards import ruler_score_group
+from openai.types.chat.chat_completion import Choice
+from openai.types.chat import ChatCompletionMessage
+
+async def main():
+    # Initial messages shared by all trajectories
+    initial_messages = [
+        {"role": "system", "content": "You are a comedy writer. Generate funny jokes based on the given topic."},
+        {"role": "user", "content": "Tell me a funny joke about computers"}
+    ]
+
+    # Create three trajectories with different quality responses
+    good_trajectory = art.Trajectory(
+        messages_and_choices=[
+            *initial_messages,
+            Choice(finish_reason="stop", index=0, message=ChatCompletionMessage(
+                role="assistant",
+                content="Why don't computers ever get invited to parties?\n\nBecause they always crash! 🥁\n\nBut seriously, have you tried turning them off and on again?"
+            ))
+        ],
+        reward=0.0
+    )
+
+    mediocre_trajectory = art.Trajectory(
+        messages_and_choices=[
+            *initial_messages,
+            Choice(finish_reason="stop", index=0, message=ChatCompletionMessage(
+                role="assistant",
+                content="What do you call a computer that doesn't work?\n\nBroken."
+            ))
+        ],
+        reward=0.0
+    )
+
+    off_topic_trajectory = art.Trajectory(
+        messages_and_choices=[
+            *initial_messages,
+            Choice(finish_reason="stop", index=0, message=ChatCompletionMessage(
+                role="assistant",
+                content="I don't really know jokes about computers, but here's a fact: The sky is blue because of Rayleigh scattering."
+            ))
+        ],
+        reward=0.0
+    )
+
+    # Create a TrajectoryGroup and use RULER to score
+    group = art.TrajectoryGroup([good_trajectory, mediocre_trajectory, off_topic_trajectory])
+    judged_group = await ruler_score_group(group, {"model": "openai/o3"}, debug=True)
+
+    # Display rankings
+    if judged_group:
+        sorted_trajectories = sorted(judged_group.trajectories, key=lambda t: t.reward, reverse=True)
+        for rank, traj in enumerate(sorted_trajectories, 1):
+            messages = traj.messages()
+            print(f"Rank {rank}: Score {traj.reward:.3f}")
+            print(f"  Response: {messages[-1]['content'][:50]}...")
+
+asyncio.run(main())
+```
+
+### Example Output
+
+```
+[RULER] Pretty-printed LLM choice JSON:
+{
+    'scores': [
+        {
+            'trajectory_id': '1',
+            'explanation': 'This joke cleverly connects computer crashes with social situations, making it relatable and humorous. It also includes a common tech support line for added humor.',
+            'score': 0.9
+        },
+        {
+            'trajectory_id': '2',
+            'explanation': "While this joke is straightforward and a pun, it's quite simple and lacks depth. Still, it stays relevant to the computer theme.",
+            'score': 0.5
+        },
+        {
+            'trajectory_id': '3',
+            'explanation': 'This trajectory fails to deliver a joke about computers, instead providing an unrelated fact, resulting in a very low score.',
+            'score': 0.1
+        }
+    ]
+}
+
+Rank 1: Score 0.900
+  Response: Why don't computers ever get invited to parties?...
+Rank 2: Score 0.500
+  Response: What do you call a computer that doesn't work?...
+Rank 3: Score 0.100
+  Response: I don't really know jokes about computers, but h...
+```
+
+## Customization
+
+### Judge Model
+
+You can use any LLM supported by LiteLLM as the judge:
+
+```python
+# Using o4-mini
+await ruler_score_group(group, {"model": "openai/o4-mini"})
+
+# Using Claude
+await ruler_score_group(group, {"model": "anthropic/claude-sonnet-4-20250514"})
+
+# Using local models
+await ruler_score_group(group, {"model": "ollama/qwen3:32b"})
+```
+
+### Custom Rubric
+
+While the default rubric works well for most tasks, you can provide a custom one:
+
+```python
+custom_rubric = """
+- Prioritize responses that are concise and clear
+- Penalize responses that include emojis or informal language
+- Reward responses that cite sources
+"""
+
+await ruler_score_group(
+    group,
+    {"model": "openai/o3"},
+    rubric=custom_rubric
+)
+```
+
+### Using Raw Message Lists
+
+If you're not using `art.Trajectory` objects, you can use the lower-level `ruler` function:
+
+```python
+from art.rewards import ruler
+
+# Each message list is a list of ChatCompletionMessageParam dicts
+message_lists = [
+    [
+        {"role": "system", "content": "You are a helpful assistant."},
+        {"role": "user", "content": "What is 2+2?"},
+        {"role": "assistant", "content": "2+2 equals 4."}
+    ],
+    # ... more trajectories
+]
+
+scores = await ruler(
+    message_lists,
+    {"model": "openai/o3"}
+)
+
+for score in scores:
+    print(f"Trajectory {score.trajectory_id}: {score.score} - {score.explanation}")
+```
+
+## Best Practices
+
+1. **Clear system prompts**: RULER uses the system prompt to understand the agent's goal. Make sure your system prompts clearly describe what the agent should do.
+
+2. **Group size**: Use 4-8 trajectories per group for optimal balance between diversity and cost. Very large groups are not recommended because they can confuse the judge.
+
+3. **Debug mode**: Enable `debug=True` to see the judge's reasoning, which helps identify scoring patterns.
+
+4. **Judge selection**: Cheaper models like Qwen3 32B often work well and are more cost-effective than larger models.
+
+## Integration with Training
+
+RULER integrates into ART's training loop using the `gather_trajectory_groups` helper with an `after_each` callback:
+
+```python
+import art
+from art.rewards import ruler_score_group
+
+# In your training loop
+groups = await art.gather_trajectory_groups(
+    (
+        art.TrajectoryGroup(
+            rollout(model, scenario) for _ in range(4)  # 4 trajectories per group
+        )
+        for scenario in batch_scenarios
+    ),
+    after_each=lambda group: ruler_score_group(
+        group,
+        {"model": "openai/o3"},
+        swallow_exceptions=True  # Return None on error, filtering out the group
+    )
+)
+
+# Train on the judged groups
+await model.train(groups)
+```
+
+The `swallow_exceptions=True` parameter is recommended in production to handle judge API failures gracefully - groups that fail to be judged are simply filtered out rather than crashing the training loop.
+
+## Performance Tips
+
+- **Caching**: RULER automatically caches judge responses to disk to avoid redundant API calls
+- **Batch processing**: Process multiple groups in parallel when possible
+- **Token efficiency**: Common prefixes are automatically deduplicated to save tokens
+
+## Troubleshooting
+
+### Low scores for all trajectories
+- Check that your system prompt clearly defines the task
+- Ensure trajectories are actually attempting the task
+- Try the default rubric before customizing
+
+### Inconsistent rankings
+- Increase group size for more stable relative rankings
+- Use a more capable judge model
+- Add more specific criteria to your rubric
+
+### High API costs
+- Use cheaper judge models (e.g., Qwen3 32B)
+- Reduce group size

examples/art-e/all_experiments.py

@@ -146,7 +146,7 @@
 
 # Model 217: like 206 but with Qwen/Qwen3-14B base model and nothink option enabled
 models["217"] = models["206"].model_copy(deep=True)
-models["217"].name = "email-agent-217-2"
+models["217"].name = "email-agent-217-3"
 models["217"].base_model = "Qwen/Qwen3-14B"
 models["217"].config.include_qwen3_nothink = True
 
@@ -203,4 +203,4 @@
 
 models["224"] = models["223"].model_copy(deep=True)
 models["224"].name = "email-agent-224"
-models["224"].config.learning_rate = 2e-6
+models["224"].config.learning_rate = 1e-6

examples/art-e/art_e/test_ruler.py

@@ -5,7 +5,7 @@
 from art_e.data.query_iterators import load_synthetic_queries
 from art_e.rollout import rollout
 from tqdm.asyncio import tqdm
-from art.rewards import art_ruler
+from art.rewards import ruler_score_group
 
 load_dotenv()
 
@@ -49,15 +49,19 @@ async def main():
         for m, t in zip(models, rollouts):
             print(f"  {m.name:10s}: {t.reward:.3f}")
 
-        judged_rollouts = await art_ruler(
-            rollouts,
+        # Create a TrajectoryGroup from the rollouts
+        group = art.TrajectoryGroup(rollouts)
+
+        judged_group = await ruler_score_group(
+            group,
             {"model": "openai/o3"},
             debug=True,
         )
 
-        print("\nGroup-judge rewards:")
-        for m, t in zip(models, judged_rollouts):
-            print(f"  {m.name:10s}: {t.reward:.3f}")
+        if judged_group:
+            print("\nRULER rewards:")
+            for m, t in zip(models, judged_group.trajectories):
+                print(f"  {m.name:10s}: {t.reward:.3f}")
 
 
 asyncio.run(main())