diff --git a/libs/cluster/Server/Migration/MigrateSessionSlots.cs b/libs/cluster/Server/Migration/MigrateSessionSlots.cs index 1089a2de2..33020408a 100644 --- a/libs/cluster/Server/Migration/MigrateSessionSlots.cs +++ b/libs/cluster/Server/Migration/MigrateSessionSlots.cs @@ -56,7 +56,7 @@ private bool MigrateSlotsDataDriver() /// public void DeleteKeysInSlot() { - if (!_copyOption) + if (_copyOption) return; ClusterManager.DeleteKeysInSlotsFromMainStore(localServerSession.BasicGarnetApi, _sslots); diff --git a/libs/cluster/Server/Migration/MigrationDriver.cs b/libs/cluster/Server/Migration/MigrationDriver.cs index e84e6e3af..a243a9611 100644 --- a/libs/cluster/Server/Migration/MigrationDriver.cs +++ b/libs/cluster/Server/Migration/MigrationDriver.cs @@ -29,8 +29,8 @@ public bool TryStartMigrationTask(out ReadOnlySpan errorMessage) return false; } - // Delete keys locally if option enabled - if (_copyOption) + // Delete keys locally if _copyOption is set to false. + if (!_copyOption) DeleteKeys(_keysWithSize); Status = MigrateState.SUCCESS; }