evaluate_existing#
- langsmith.evaluation._runner.evaluate_existing(experiment: str | UUID | TracerSession, /, evaluators: Sequence[RunEvaluator | Callable[[Run, Example | None], EvaluationResult | EvaluationResults] | Callable[[...], dict | EvaluationResults | EvaluationResult]] | None = None, summary_evaluators: Sequence[Callable[[Sequence[Run], Sequence[Example]], EvaluationResult | EvaluationResults] | Callable[[List[Run], List[Example]], EvaluationResult | EvaluationResults]] | None = None, metadata: dict | None = None, max_concurrency: int | None = 0, client: Client | None = None, load_nested: bool = False, blocking: bool = True) ExperimentResults [source]#
Evaluate existing experiment runs.
- Parameters:
experiment (Union[str, uuid.UUID]) β The identifier of the experiment to evaluate.
data (DATA_T) β The data to use for evaluation.
evaluators (Optional[Sequence[EVALUATOR_T]]) β Optional sequence of evaluators to use for individual run evaluation.
summary_evaluators (Optional[Sequence[SUMMARY_EVALUATOR_T]]) β Optional sequence of evaluators to apply over the entire dataset.
metadata (Optional[dict]) β Optional metadata to include in the evaluation results.
max_concurrency (int | None) β The maximum number of concurrent evaluations to run. If None then no limit is set. If 0 then no concurrency. Defaults to 0.
client (Optional[langsmith.Client]) β Optional Langsmith client to use for evaluation.
load_nested (bool) β Whether to load all child runs for the experiment. Default is to only load the top-level root runs.
blocking (bool) β Whether to block until evaluation is complete.
- Returns:
The evaluation results.
- Return type:
- Environment:
- LANGSMITH_TEST_CACHE: If set, API calls will be cached to disk to save time and
cost during testing. Recommended to commit the cache files to your repository for faster CI/CD runs. Requires the βlangsmith[vcr]β package to be installed.
Examples
>>> from langsmith.evaluation import evaluate, evaluate_existing >>> dataset_name = "Evaluate Examples" >>> def predict(inputs: dict) -> dict: ... # This can be any function or just an API call to your app. ... return {"output": "Yes"} >>> # First run inference on the dataset ... results = evaluate( ... predict, ... data=dataset_name, ... ) View the evaluation results for experiment:... >>> # Then apply evaluators to the experiment ... def accuracy(run: Run, example: Example): ... # Row-level evaluator for accuracy. ... pred = run.outputs["output"] ... expected = example.outputs["answer"] ... return {"score": expected.lower() == pred.lower()} >>> def precision(runs: Sequence[Run], examples: Sequence[Example]): ... # Experiment-level evaluator for precision. ... # TP / (TP + FP) ... predictions = [run.outputs["output"].lower() for run in runs] ... expected = [example.outputs["answer"].lower() for example in examples] ... # yes and no are the only possible answers ... tp = sum([p == e for p, e in zip(predictions, expected) if p == "yes"]) ... fp = sum([p == "yes" and e == "no" for p, e in zip(predictions, expected)]) ... return {"score": tp / (tp + fp)} >>> experiment_name = ( ... results.experiment_name ... ) # Can use the returned experiment name >>> experiment_name = "My Experiment:64e6e91" # Or manually specify >>> results = evaluate_existing( ... experiment_name, ... summary_evaluators=[precision], ... ) View the evaluation results for experiment:...