docs: private void doRun() {
          if (migrationInfo.startProcessing()) {
              try {
                  if (firstFragment) {
                      executeBeforeMigrations();
                  }
  
                  for (Operation migrationOperation : fragmentMigrationState.getMigrationOperations()) {
                      runMigrationOperation(migrationOperation);
                  }
  
                  success = true;
              } catch (Throwable e) {
                  failureReason = e;
                  getLogger().severe("Error while executing replication operations " + migrationInfo, e);
              } finally {
                  afterMigrate();
              }
          } else {
              logMigrationCancelled();
          }
      }