map() — langchain Function Reference

Architecture documentation for the map() function in config.py from the langchain codebase.

Function python LangChainCore Runnables called by 1

Entity Profile

LangChainCore→ Runnables→ map() — langchain Function Reference

Dependency Diagram

graph TD
  1242c34c_6f5a_3715_6044_ca34306cfcac["map()"]
  f583706a_3a1c_dd8c_fb44_0b58eb65f827["ContextThreadPoolExecutor"]
  1242c34c_6f5a_3715_6044_ca34306cfcac -->|defined in| f583706a_3a1c_dd8c_fb44_0b58eb65f827
  849ca24e_ae2b_f5c9_49cf_256b45cd8833["get_config_list()"]
  849ca24e_ae2b_f5c9_49cf_256b45cd8833 -->|calls| 1242c34c_6f5a_3715_6044_ca34306cfcac
  style 1242c34c_6f5a_3715_6044_ca34306cfcac fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/langchain_core/runnables/config.py lines 550–576

    def map(
        self,
        fn: Callable[..., T],
        *iterables: Iterable[Any],
        **kwargs: Any,
    ) -> Iterator[T]:
        """Map a function to multiple iterables.

        Args:
            fn: The function to map.
            *iterables: The iterables to map over.
            timeout: The timeout for the map.
            chunksize: The chunksize for the map.

        Returns:
            The iterator for the mapped function.
        """
        contexts = [copy_context() for _ in range(len(iterables[0]))]  # type: ignore[arg-type]

        def _wrapped_fn(*args: Any) -> T:
            return contexts.pop().run(fn, *args)

        return super().map(
            _wrapped_fn,
            *iterables,
            **kwargs,
        )