diff --git a/core/modules/migrate/src/Entity/Migration.php b/core/modules/migrate/src/Entity/Migration.php index 61d9e66..0791750 100644 --- a/core/modules/migrate/src/Entity/Migration.php +++ b/core/modules/migrate/src/Entity/Migration.php @@ -408,11 +408,7 @@ public function setProcess(array $process) { * {@inheritdoc} */ public function setProcessOfProperty($field_name, $process) { - $this->process[$field_name] = $process; - // Normalize the entire process array if this process was a shorthand get. - if (is_string($process)) { - $this->process = $this->getProcessNormalized($this->process); - } + $this->process = $this->getProcessNormalized([$field_name => $process]) + $this->process; return $this; } @@ -423,7 +419,7 @@ public function mergeProcessOfProperty($field_name, array $process) { // If we already have a process value then merge the incoming process array //otherwise simply set it. if (isset($this->process[$field_name])) { - $this->process = NestedArray::mergeDeepArray([$this->process, [$field_name => $process]], TRUE); + $this->process = NestedArray::mergeDeepArray([$this->process, $this->getProcessNormalized([$field_name => $process])], TRUE); } else { $this->setProcessOfProperty($field_name, $process);