function MigrateExecutableTest::testProcessRowPipelineException

Tests the processRow pipeline exception.

File

core/modules/migrate/tests/src/Unit/MigrateExecutableTest.php, line 331

Class

MigrateExecutableTest

@coversDefaultClass \Drupal\migrate\MigrateExecutable @group migrate

Namespace

Code

public function testProcessRowPipelineException() : void {
    $row = new Row();
    $plugin = $this->prophesize(MigrateProcessInterface::class);
    $plugin->getPluginDefinition()
        ->willReturn([
        'handle_multiples' => FALSE,
    ]);
    $plugin->transform(NULL, $this->executable, $row, 'destination_id')
        ->willReturn('transform_return_string');
    $plugin->multiple()
        ->willReturn(TRUE);
    $plugin->getPluginId()
        ->willReturn('plugin_id');
    $plugin->reset()
        ->shouldBeCalled();
    $plugin->isPipelineStopped()
        ->willReturn(FALSE);
    $plugin = $plugin->reveal();
    $plugins['destination_id'] = [
        $plugin,
        $plugin,
    ];
    $this->migration
        ->method('getProcessPlugins')
        ->willReturn($plugins);
    $this->expectException(MigrateException::class);
    $this->expectExceptionMessage('Pipeline failed at plugin_id plugin for destination destination_id: transform_return_string received instead of an array,');
    $this->executable
        ->processRow($row);
}