RunManager Class — langchain Architecture

Architecture documentation for the RunManager class in manager.py from the langchain codebase.

Class python

Entity Profile

Dependency Diagram

graph TD
  9ee9bc25_3f67_6972_bad7_11cbc05986ad["RunManager"]
  3634d69d_8115_bbc7_d255_98aa30244c71["BaseRunManager"]
  9ee9bc25_3f67_6972_bad7_11cbc05986ad -->|extends| 3634d69d_8115_bbc7_d255_98aa30244c71
  35cf5db6_bcb1_b854_6ebb_5e0368e51b58["manager.py"]
  9ee9bc25_3f67_6972_bad7_11cbc05986ad -->|defined in| 35cf5db6_bcb1_b854_6ebb_5e0368e51b58
  06d4aa4b_4b31_a5d7_fe56_638a1afb1cd9["on_text()"]
  9ee9bc25_3f67_6972_bad7_11cbc05986ad -->|method| 06d4aa4b_4b31_a5d7_fe56_638a1afb1cd9
  8cb747b1_61c9_0441_04c4_f2ec3010ec59["on_retry()"]
  9ee9bc25_3f67_6972_bad7_11cbc05986ad -->|method| 8cb747b1_61c9_0441_04c4_f2ec3010ec59

Relationship Graph

Source Code

libs/core/langchain_core/callbacks/manager.py lines 513–563

class RunManager(BaseRunManager):
    """Synchronous run manager."""

    def on_text(
        self,
        text: str,
        **kwargs: Any,
    ) -> None:
        """Run when a text is received.

        Args:
            text: The received text.
            **kwargs: Additional keyword arguments.
        """
        if not self.handlers:
            return
        handle_event(
            self.handlers,
            "on_text",
            None,
            text,
            run_id=self.run_id,
            parent_run_id=self.parent_run_id,
            tags=self.tags,
            **kwargs,
        )

    def on_retry(
        self,
        retry_state: RetryCallState,
        **kwargs: Any,
    ) -> None:
        """Run when a retry is received.

        Args:
            retry_state: The retry state.
            **kwargs: Additional keyword arguments.

        """
        if not self.handlers:
            return
        handle_event(
            self.handlers,
            "on_retry",
            "ignore_retry",
            retry_state,
            run_id=self.run_id,
            parent_run_id=self.parent_run_id,
            tags=self.tags,
            **kwargs,
        )