docs: void retainCompletedMigrations(Collection<MigrationInfo> migrations) {
          partitionServiceLock.lock();
          try {
              completedMigrations.retainAll(migrations);
          } finally {
              partitionServiceLock.unlock();
          }
      }