aupdate() — langchain Function Reference

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

Function python DataProcessing DocumentLoaders calls 2 called by 1

Entity Profile

DataProcessing→ DocumentLoaders→ aupdate() — langchain Function Reference

Dependency Diagram

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

Relationship Graph

Source Code

libs/core/langchain_core/indexing/base.py lines 306–328

    async def aupdate(
        self,
        keys: Sequence[str],
        *,
        group_ids: Sequence[str | None] | None = None,
        time_at_least: float | None = None,
    ) -> None:
        """Async 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.
                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!
        """
        self.update(keys, group_ids=group_ids, time_at_least=time_at_least)