_drain_queue() — langchain Function Reference

Architecture documentation for the _drain_queue() function in shell_tool.py from the langchain codebase.

Function python LangChainCore Runnables called by 1

Entity Profile

LangChainCore→ Runnables→ _drain_queue() — langchain Function Reference

Dependency Diagram

graph TD
  6de1caf7_edd6_8519_6774_9efe986ad3fe["_drain_queue()"]
  cf4eeaa4_4bcc_69d9_a0f3_664b1eecb4e8["ShellSession"]
  6de1caf7_edd6_8519_6774_9efe986ad3fe -->|defined in| cf4eeaa4_4bcc_69d9_a0f3_664b1eecb4e8
  da18dc22_e4fc_2b4a_2829_9217c9f5d8f5["execute()"]
  da18dc22_e4fc_2b4a_2829_9217c9f5d8f5 -->|calls| 6de1caf7_edd6_8519_6774_9efe986ad3fe
  style 6de1caf7_edd6_8519_6774_9efe986ad3fe fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/langchain_v1/langchain/agents/middleware/shell_tool.py lines 417–422

    def _drain_queue(self) -> None:
        while True:
            try:
                self._queue.get_nowait()
            except queue.Empty:
                break