_batch() — langchain Function Reference

Architecture documentation for the _batch() function in test_runnable.py from the langchain codebase.

Function python LangChainCore Runnables called by 1

Entity Profile

LangChainCore→ Runnables→ _batch() — langchain Function Reference

Dependency Diagram

graph TD
  a92288d5_3ea4_6080_81b2_e09426cb961e["_batch()"]
  192ffa80_aa8c_9fdf_71de_8d2c6c5ac8d1["ControlledExceptionRunnable"]
  a92288d5_3ea4_6080_81b2_e09426cb961e -->|defined in| 192ffa80_aa8c_9fdf_71de_8d2c6c5ac8d1
  ddb31a72_b9b1_0f3c_afc0_e5a9b2ad7fc4["test_seq_batch_return_exceptions()"]
  ddb31a72_b9b1_0f3c_afc0_e5a9b2ad7fc4 -->|calls| a92288d5_3ea4_6080_81b2_e09426cb961e
  style a92288d5_3ea4_6080_81b2_e09426cb961e fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/tests/unit_tests/runnables/test_runnable.py lines 4188–4203

        def _batch(
            self,
            inputs: list[str],
        ) -> list[str | Exception]:
            outputs: list[str | Exception] = []
            for value in inputs:
                if value.startswith(self.fail_starts_with):
                    outputs.append(
                        ValueError(
                            f"ControlledExceptionRunnable({self.fail_starts_with}) "
                            f"fail for {value}"
                        )
                    )
                else:
                    outputs.append(value + "a")
            return outputs