function Migration::allRowsProcessed

Overrides MigrationInterface::allRowsProcessed

File

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

Class

Migration: Defines the Migration plugin.

Namespace

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;
}