diff --git a/sources/content/src/ContentEntitySourcePluginUi.php b/sources/content/src/ContentEntitySourcePluginUi.php
index 58003c4..9fad9a4 100644
--- a/sources/content/src/ContentEntitySourcePluginUi.php
+++ b/sources/content/src/ContentEntitySourcePluginUi.php
@@ -248,10 +248,19 @@ class ContentEntitySourcePluginUi extends SourcePluginUiBase {
     foreach ($entities as $entity) {
       /* @var $entity \Drupal\Core\Entity\EntityInterface */
       $source_lang = $entity->language()->getId();
-
       try {
-        // For given source lang no job exists yet.
-        if (!isset($source_lang_registry[$source_lang])) {
+        if(tmgmt_job_item_load_latest('content', $entity->getEntityTypeId(), $entity->id(), $source_lang)) {
+          drupal_set_message('Already exist active job items for selected sources.', 'warning');
+        }
+        elseif($all_latest_items = tmgmt_job_item_load_all_latest('content', $entity->getEntityTypeId(), $entity->id(), $source_lang)) {
+          foreach($all_latest_items as $item) {
+            // Create new job item.
+            $job = $item->getJob();
+            $job->addItem('content', $type, $entity->id());
+            $jobs[$job->id()] = $job;
+          }
+        }
+        else {
           // Create new job.
           $job = tmgmt_job_create($source_lang, LanguageInterface::LANGCODE_NOT_SPECIFIED, \Drupal::currentUser()->id());
           // Add initial job item.
@@ -261,11 +270,6 @@ class ContentEntitySourcePluginUi extends SourcePluginUiBase {
           // Add newly created job into jobs queue.
           $jobs[$job->id()] = $job;
         }
-        // We have a job for given source lang, so just add new job item for the
-        // existing job.
-        else {
-          $jobs[$source_lang_registry[$source_lang]]->addItem('content', $type, $entity->id());
-        }
       } catch (TMGMTException $e) {
         watchdog_exception('tmgmt', $e);
         drupal_set_message($this->t('Unable to add job item for entity %name: %error.', array(
@@ -274,7 +278,6 @@ class ContentEntitySourcePluginUi extends SourcePluginUiBase {
         )), 'error');
       }
     }
-
     // If necessary, do a redirect.
     $redirects = tmgmt_job_checkout_multiple($jobs);
     if ($redirects) {