github/langchain
1
0
Fork 0
mirror of https://github.com/hwchase17/langchain.git synced 2025-09-25 04:49:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

core: Bump ruff version to 0.11 (#30519)

Browse Source 
Changes are from the new TC006 rule:
https://docs.astral.sh/ruff/rules/runtime-cast-value/
TC006 is auto-fixed.
This commit is contained in:
Christophe Bornet
2025-03-27 18:01:49 +01:00
committed by GitHub
parent 59908f04d4
commit e181d43214
44 changed files with 243 additions and 233 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
libs/core/langchain_core/indexing/api.py
View File

@@ -395,7 +395,7 @@ def index(
if cleanup == "scoped_full":
scoped_full_cleanup_source_ids.add(source_id)
# source ids cannot be None after for loop above.
source_ids = cast(Sequence[str], source_ids) # type: ignore[assignment]
source_ids = cast("Sequence[str]", source_ids) # type: ignore[assignment]
exists_batch = record_manager.exists([doc.uid for doc in hashed_docs])
@@ -461,7 +461,7 @@ def index(
)
raise AssertionError(msg)
_source_ids = cast(Sequence[str], source_ids)
_source_ids = cast("Sequence[str]", source_ids)
uids_to_delete = record_manager.list_keys(
group_ids=_source_ids, before=index_start_dt
@@ -710,7 +710,7 @@ async def aindex(
if cleanup == "scoped_full":
scoped_full_cleanup_source_ids.add(source_id)
# source ids cannot be None after for loop above.
source_ids = cast(Sequence[str], source_ids)
source_ids = cast("Sequence[str]", source_ids)
exists_batch = await record_manager.aexists([doc.uid for doc in hashed_docs])
@@ -776,7 +776,7 @@ async def aindex(
)
raise AssertionError(msg)
_source_ids = cast(Sequence[str], source_ids)
_source_ids = cast("Sequence[str]", source_ids)
uids_to_delete = await record_manager.alist_keys(
group_ids=_source_ids, before=index_start_dt

2
libs/core/langchain_core/indexing/in_memory.py
View File

@@ -41,7 +41,7 @@ class InMemoryDocumentIndex(DocumentIndex):
id_ = item.id
self.store[id_] = item_
ok_ids.append(cast(str, item_.id))
ok_ids.append(cast("str", item_.id))
return UpsertResponse(succeeded=ok_ids, failed=[])