RPM importer needs to handle when unit already exists.

closes #1643
pulp · Feb 9, 2016 · ca5c104 · ca5c104
1 parent 5c48348
commit ca5c104
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/plugins/pulp_rpm/plugins/importers/yum/sync.py b/plugins/pulp_rpm/plugins/importers/yum/sync.py
@@ -12,6 +12,7 @@
 from cStringIO import StringIO
 from urlparse import urljoin
 
+from mongoengine import NotUniqueError
 from nectar.request import DownloadRequest
 
 from pulp.common.plugins import importer_constants
@@ -601,7 +602,10 @@ def add_rpm_unit(self, metadata_files, unit):
         """
         metadata_files.add_repodata(unit)
         unit.set_storage_path(unit.filename)
-        unit.save()
+        try:
+            unit.save()
+        except NotUniqueError:
+            unit = unit.__class__.objects.filter(**unit.unit_key).first()
         repo_controller.associate_single_unit(self.conduit.repo, unit)
         self.progress_report['content'].success(unit)
         self.conduit.set_progress(self.progress_report)