Skip to content

feat(migrator): [7/7] Migration performance benchmarks with throughput, latency, memory measurement, and visualization #566

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
nkanu17 wants to merge 6 commits into
base: feat/migrate-cli-docs
Choose a base branch
from
Open

feat(migrator): [7/7] Migration performance benchmarks with throughput, latency, memory measurement, and visualization #566

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
6 commits
Select commit Hold shift + click to select a range
ebdbbcd
feat(migrate): [7/7] add migration performance benchmarks with throug…
nkanu17 Apr 1, 2026
493f4b2
fix: benchmark bug fixes and improvements (#566)
nkanu17 Apr 1, 2026
ae07a21
fix: use flushdb instead of flushall in retrieval benchmark (#566)
nkanu17 Apr 1, 2026
ce034f7
chore: low priority cleanup across migration stack
nkanu17 Apr 2, 2026
5e686ce
fix: address review round 3 for migrate-benchmarks (#566)
nkanu17 Apr 2, 2026
63d7c94
style: auto-format after rebase cascade
nkanu17 Apr 2, 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
3 changes: 1 addition & 2 deletions redisvl/migration/async_executor.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -739,8 +739,7 @@ def _notify(step: str, detail: Optional[str] = None) -> None:
effective_changes = datatype_changes
if has_field_renames and not resuming_from_checkpoint:
field_rename_map = {
fr.old_name: fr.new_name
for fr in rename_ops.rename_fields
fr.old_name: fr.new_name for fr in rename_ops.rename_fields
}
effective_changes = {
field_rename_map.get(k, k): v
Expand Down
3 changes: 1 addition & 2 deletions redisvl/migration/executor.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -763,8 +763,7 @@ def _notify(step: str, detail: Optional[str] = None) -> None:
effective_changes = datatype_changes
if has_field_renames and not resuming_from_checkpoint:
field_rename_map = {
fr.old_name: fr.new_name
for fr in rename_ops.rename_fields
fr.old_name: fr.new_name for fr in rename_ops.rename_fields
}
effective_changes = {
field_rename_map.get(k, k): v
Expand Down
4 changes: 1 addition & 3 deletions redisvl/migration/models.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -78,9 +78,7 @@ class RenameOperations(BaseModel):
@property
def has_operations(self) -> bool:
return bool(
self.rename_index
or self.change_prefix is not None
or self.rename_fields
self.rename_index or self.change_prefix is not None or self.rename_fields
)


Expand Down
Loading
Loading