docs: void scheduleActiveMigrationFinalization(final MigrationInfo migrationInfo) {
          partitionServiceLock.lock();
          try {
              if (migrationInfo.equals(activeMigrationInfo)) {
                  if (activeMigrationInfo.startProcessing()) {
                      activeMigrationInfo.setStatus(migrationInfo.getStatus());
                      finalizeMigration(activeMigrationInfo);
                  } else {
                      // This case happens when master crashes while migration operation is running
                      // and new master publishes the latest completed migrations
                      // after collecting active and completed migrations from existing members.
                      // See FetchMostRecentPartitionTableTask.
                      logger.info("Scheduling finalization of " + migrationInfo
                              + ", because migration process is currently running.");
                      nodeEngine.getExecutionService().schedule(() ->
                              scheduleActiveMigrationFinalization(migrationInfo), 1, TimeUnit.SECONDS);
                  }
                  return;
              }
  
              PartitionReplica source = migrationInfo.getSource();
              if (source != null && migrationInfo.getSourceCurrentReplicaIndex() > 0
                      && source.isIdentical(node.getLocalMember())) {
                  // Finalize migration on old backup replica owner
                  finalizeMigration(migrationInfo);
              }
          } finally {
              partitionServiceLock.unlock();
          }
      }