Skip to content

fix(qdrant): add pandas dep, fix cross-repo ID collisions, fix comment indexing #2323

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
gvago wants to merge 2 commits into
base: main
Choose a base branch
from
+17 −4
Open

fix(qdrant): add pandas dep, fix cross-repo ID collisions, fix comment indexing #2323

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
f114d4c
fix(qdrant): add pandas dep, fix cross-repo ID collisions, fix commen…
gvago Apr 14, 2026
d1b7a85
fix: address review feedback — break long PointStruct line, clarify p…
gvago Apr 15, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
20 changes: 16 additions & 4 deletions pr_agent/tools/pr_similar_issue.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -445,7 +445,7 @@ def _update_index_with_issues(self, issues_list, repo_name_for_index, upsert=Fal
if len(comment_body) < 8000 or \
self.token_handler.count_tokens(comment_body) < MAX_TOKENS[MODEL]:
comment_record = Record(
id=issue_key + ".comment_" + str(j + 1),
id=issue_key + ".comment_" + str(j),
text=comment_body,
metadata=Metadata(repo=repo_name_for_index,
username=username, # use issue username for all comments
Expand Down Expand Up @@ -541,7 +541,7 @@ def _update_table_with_issues(self, issues_list, repo_name_for_index, ingest=Fal
if len(comment_body) < 8000 or \
self.token_handler.count_tokens(comment_body) < MAX_TOKENS[MODEL]:
comment_record = Record(
id=issue_key + ".comment_" + str(j + 1),
id=issue_key + ".comment_" + str(j),
text=comment_body,
metadata=Metadata(repo=repo_name_for_index,
username=username, # use issue username for all comments
Expand Down Expand Up @@ -639,7 +639,7 @@ def _update_qdrant_with_issues(self, issues_list, repo_name_for_index, ingest=Fa
if len(comment_body) < 8000 or \
self.token_handler.count_tokens(comment_body) < MAX_TOKENS[MODEL]:
comment_record = Record(
id=issue_key + ".comment_" + str(j + 1),
id=issue_key + ".comment_" + str(j),
text=comment_body,
metadata=Metadata(repo=repo_name_for_index,
username=username,
Expand Down Expand Up @@ -672,8 +672,20 @@ def _update_qdrant_with_issues(self, issues_list, repo_name_for_index, ingest=Fa
get_logger().info('Upserting into Qdrant...')
points = []
for row in df.to_dict(orient="records"):
point_uuid = uuid.uuid5(
uuid.NAMESPACE_DNS,
f"{repo_name_for_index}:{row['id']}",
).hex
points.append(
PointStruct(id=uuid.uuid5(uuid.NAMESPACE_DNS, row["id"]).hex, vector=row["vector"], payload={"id": row["id"], "text": row["text"], "metadata": row["metadata"]})
PointStruct(
id=point_uuid,
vector=row["vector"],
payload={
"id": row["id"],
"text": row["text"],
"metadata": row["metadata"],
},
)
)
self.qdrant.upsert(collection_name=self.index_name, points=points)
get_logger().info('Done')
Expand Down
1 change: 1 addition & 0 deletions requirements.txt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -39,6 +39,7 @@ giteapy==1.0.8
# pinecone-datasets @ git+https://github.com/mrT23/pinecone-datasets.git@main
# lancedb==0.5.1
# qdrant-client==1.15.1
# pandas # required by qdrant and pinecone indexing paths
# uncomment this to support language LangChainOpenAIHandler
# langchain==0.2.0
# langchain-core==0.2.28
Expand Down
Loading