LangChain Reference home pageLangChain ReferenceLangChain Reference
  • GitHub
  • Main Docs
Deep Agents
LangChain
LangGraph
Integrations
LangSmith
  • Overview
    • Overview
    • Graphs
    • Functional API
    • Pregel
    • Checkpointing
    • Storage
    • Caching
    • Types
    • Runtime
    • Config
    • Errors
    • Constants
    • Channels
    • Agents
    LangGraph Checkpoint
    LangGraph Store
    Checkpoint Postgres
    Store Postgres
    Checkpoint SQLite
    LangGraph Prebuilt
    LangGraph CLI
    LangGraph SDK
    LangGraph Supervisor
    LangGraph Swarm
    ⌘I

    LangChain Assistant

    Ask a question to get started

    Enter to send•Shift+Enter new line

    Menu

    OverviewGraphsFunctional APIPregelCheckpointingStorageCachingTypesRuntimeConfigErrorsConstantsChannelsAgents
    LangGraph Checkpoint
    LangGraph Store
    Checkpoint Postgres
    Store Postgres
    Checkpoint SQLite
    LangGraph Prebuilt
    LangGraph CLI
    LangGraph SDK
    LangGraph Supervisor
    LangGraph Swarm
    Language
    Theme
    Pythonlanggraphpregel_runnerFuturesDict
    Classā—Since v0.6

    FuturesDict

    Copy
    FuturesDict(
      self,
      event: E,
      callback: weakref.ref[Callable[[PregelExecutableTask

    Bases

    Generic[F, E]dict[F, PregelExecutableTask | None]

    Constructors

    Attributes

    Methods

    View source on GitHub
    ,
    BaseException
    |
    None
    ]
    ,
    None
    ]
    ]
    ,
    should_stop
    :
    Callable
    [
    [
    set
    [
    F
    ]
    ]
    ,
    bool
    ]
    ,
    future_type
    :
    type
    [
    F
    ]
    )
    constructor
    __init__
    NameType
    eventE
    callbackweakref.ref[Callable[[PregelExecutableTask, BaseException | None], None]]
    should_stopCallable[[set[F]], bool]
    future_typetype[F]
    attribute
    event: E
    attribute
    callback: weakref.ref[Callable[[PregelExecutableTask, BaseException | None], None]]
    attribute
    should_stop: Callable[[set[F]], bool]
    attribute
    counter: int
    attribute
    done: set[F]
    attribute
    lock: threading.Lock
    method
    on_done