Skip to content

Commit 01d3025

Browse files
committed
chore: remove legacy backup fallback from sync and async executors
1 parent 5671e6f commit 01d3025

2 files changed

Lines changed: 0 additions & 24 deletions

File tree

redisvl/migration/async_executor.py

Lines changed: 0 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -576,18 +576,6 @@ async def apply(
576576
)
577577
existing_backup = VectorBackup.load(backup_path)
578578

579-
# Fallback: probe for legacy backup filename (pre-hash naming)
580-
if existing_backup is None:
581-
legacy_path = str(Path(backup_dir) / f"migration_backup_{safe_name}")
582-
legacy_backup = VectorBackup.load(legacy_path)
583-
if legacy_backup is not None:
584-
logger.info(
585-
"Found legacy backup at %s (pre-hash naming), using it",
586-
legacy_path,
587-
)
588-
existing_backup = legacy_backup
589-
backup_path = legacy_path
590-
591579
if existing_backup is not None:
592580
if existing_backup.header.index_name != plan.source.index_name:
593581
existing_backup = None

redisvl/migration/executor.py

Lines changed: 0 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -648,18 +648,6 @@ def apply(
648648
)
649649
existing_backup = VectorBackup.load(backup_path)
650650

651-
# Fallback: probe for legacy backup filename (pre-hash naming)
652-
if existing_backup is None:
653-
legacy_path = str(Path(backup_dir) / f"migration_backup_{safe_name}")
654-
legacy_backup = VectorBackup.load(legacy_path)
655-
if legacy_backup is not None:
656-
logger.info(
657-
"Found legacy backup at %s (pre-hash naming), using it",
658-
legacy_path,
659-
)
660-
existing_backup = legacy_backup
661-
backup_path = legacy_path
662-
663651
if existing_backup is not None:
664652
if existing_backup.header.index_name != plan.source.index_name:
665653
logger.warning(

0 commit comments

Comments
 (0)