list_keys() — langchain Function Reference

Architecture documentation for the list_keys() function in _sql_record_manager.py from the langchain codebase.

Function python LangChainCore ApiManagement calls 1

Entity Profile

LangChainCore→ ApiManagement→ list_keys() — langchain Function Reference

Dependency Diagram

graph TD
  6a4e1403_b0a8_90d5_36ca_e8b30d6195fe["list_keys()"]
  9d7938c1_1c25_4cae_be80_9fc00a5ed077["SQLRecordManager"]
  6a4e1403_b0a8_90d5_36ca_e8b30d6195fe -->|defined in| 9d7938c1_1c25_4cae_be80_9fc00a5ed077
  82b22123_4423_ea4d_765a_075b780b8c2e["_make_session()"]
  6a4e1403_b0a8_90d5_36ca_e8b30d6195fe -->|calls| 82b22123_4423_ea4d_765a_075b780b8c2e
  style 6a4e1403_b0a8_90d5_36ca_e8b30d6195fe fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/langchain/langchain_classic/indexes/_sql_record_manager.py lines 451–476

    def list_keys(
        self,
        *,
        before: float | None = None,
        after: float | None = None,
        group_ids: Sequence[str] | None = None,
        limit: int | None = None,
    ) -> list[str]:
        """List records in the SQLite database based on the provided date range."""
        session: Session
        with self._make_session() as session:
            query: Query = session.query(UpsertionRecord).filter(
                UpsertionRecord.namespace == self.namespace,
            )

            if after:
                query = query.filter(UpsertionRecord.updated_at > after)
            if before:
                query = query.filter(UpsertionRecord.updated_at < before)
            if group_ids:
                query = query.filter(UpsertionRecord.group_id.in_(group_ids))

            if limit:
                query = query.limit(limit)
            records = query.all()
        return [r.key for r in records]