aupdate() — langchain Function Reference

Architecture documentation for the aupdate() function in base.py from the langchain codebase.

Function python DataProcessing VectorStores calls 1 called by 1

Entity Profile

DataProcessing→ VectorStores→ aupdate() — langchain Function Reference

Dependency Diagram

graph TD
  9af363b3_2b89_2789_0325_7ba5ddddc6e3["aupdate()"]
  cc7bb185_d3e3_eb58_9979_a81c90c9cc33["RecordManager"]
  9af363b3_2b89_2789_0325_7ba5ddddc6e3 -->|defined in| cc7bb185_d3e3_eb58_9979_a81c90c9cc33
  c01fa23b_401c_9c3f_6a58_f302cfe5d794["aupdate()"]
  c01fa23b_401c_9c3f_6a58_f302cfe5d794 -->|calls| 9af363b3_2b89_2789_0325_7ba5ddddc6e3
  c01fa23b_401c_9c3f_6a58_f302cfe5d794["aupdate()"]
  9af363b3_2b89_2789_0325_7ba5ddddc6e3 -->|calls| c01fa23b_401c_9c3f_6a58_f302cfe5d794
  style 9af363b3_2b89_2789_0325_7ba5ddddc6e3 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/langchain_core/indexing/base.py lines 127–152

    async def aupdate(
        self,
        keys: Sequence[str],
        *,
        group_ids: Sequence[str | None] | None = None,
        time_at_least: float | None = None,
    ) -> None:
        """Asynchronously upsert records into the database.

        Args:
            keys: A list of record keys to upsert.
            group_ids: A list of group IDs corresponding to the keys.
            time_at_least: Optional timestamp. Implementation can use this
                to optionally verify that the timestamp IS at least this time
                in the system that stores the data.

                e.g., use to validate that the time in the postgres database
                is equal to or larger than the given timestamp, if not
                raise an error.

                This is meant to help prevent time-drift issues since
                time may not be monotonically increasing!

        Raises:
            ValueError: If the length of keys doesn't match the length of group_ids.
        """