AsyncRunManager Class — langchain Architecture

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

Class python

Entity Profile

Dependency Diagram

graph TD
  c60784e6_5104_0024_72d7_0eea827420d1["AsyncRunManager"]
  3634d69d_8115_bbc7_d255_98aa30244c71["BaseRunManager"]
  c60784e6_5104_0024_72d7_0eea827420d1 -->|extends| 3634d69d_8115_bbc7_d255_98aa30244c71
  35cf5db6_bcb1_b854_6ebb_5e0368e51b58["manager.py"]
  c60784e6_5104_0024_72d7_0eea827420d1 -->|defined in| 35cf5db6_bcb1_b854_6ebb_5e0368e51b58
  51aca28c_2530_69ad_744f_06db64a356c1["get_sync()"]
  c60784e6_5104_0024_72d7_0eea827420d1 -->|method| 51aca28c_2530_69ad_744f_06db64a356c1
  a83fff66_afd1_c07d_95ee_3fc78a4c6ea1["on_text()"]
  c60784e6_5104_0024_72d7_0eea827420d1 -->|method| a83fff66_afd1_c07d_95ee_3fc78a4c6ea1
  5081203a_ccd7_b701_52e7_b362ef90c44c["on_retry()"]
  c60784e6_5104_0024_72d7_0eea827420d1 -->|method| 5081203a_ccd7_b701_52e7_b362ef90c44c

Relationship Graph

Source Code

libs/core/langchain_core/callbacks/manager.py lines 588–647

class AsyncRunManager(BaseRunManager, ABC):
    """Async run manager."""

    @abstractmethod
    def get_sync(self) -> RunManager:
        """Get the equivalent sync `RunManager`.

        Returns:
            The sync `RunManager`.

        """

    async 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
        await ahandle_event(
            self.handlers,
            "on_text",
            None,
            text,
            run_id=self.run_id,
            parent_run_id=self.parent_run_id,
            tags=self.tags,
            **kwargs,
        )

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

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

        """
        if not self.handlers:
            return
        await ahandle_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,
        )