function Migration::allRowsProcessed

Same name in other branches
  1. 8.9.x core/modules/migrate/src/Plugin/Migration.php \Drupal\migrate\Plugin\Migration::allRowsProcessed()
  2. 10 core/modules/migrate/src/Plugin/Migration.php \Drupal\migrate\Plugin\Migration::allRowsProcessed()
  3. 11.x core/modules/migrate/src/Plugin/Migration.php \Drupal\migrate\Plugin\Migration::allRowsProcessed()

Overrides MigrationInterface::allRowsProcessed

File

core/modules/migrate/src/Plugin/Migration.php, line 598

Class

Migration
Defines the Migration plugin.

Namespace

Drupal\migrate\Plugin

Code

public function allRowsProcessed() {
    $source_count = $this->getSourcePlugin()
        ->count();
    // If the source is uncountable, we have no way of knowing if it's
    // complete, so stipulate that it is.
    if ($source_count < 0) {
        return TRUE;
    }
    $processed_count = $this->getIdMap()
        ->processedCount();
    // We don't use == because in some circumstances (like unresolved stubs
    // being created), the processed count may be higher than the available
    // source rows.
    return $source_count <= $processed_count;
}

Buggy or inaccurate documentation? Please file an issue. Need support? Need help programming? Connect with the Drupal community.