summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorÉtienne Loks <etienne.loks@proxience.com>2015-06-18 04:16:42 +0200
committerÉtienne Loks <etienne.loks@proxience.com>2015-06-18 04:16:42 +0200
commit3e0ade895bc1100181d51440227e3b4201f58a74 (patch)
treed420631df8470942d2ce7ab63e909ebdd746a017
parentb76052c0c76d2d8e42d93ad7ddbadcaafe06e0fc (diff)
parent0db36c5e136bba3048bebbe1fda8f8c55afdec36 (diff)
downloadIshtar-3e0ade895bc1100181d51440227e3b4201f58a74.tar.bz2
Ishtar-3e0ade895bc1100181d51440227e3b4201f58a74.zip
Merge branch 'stable'
-rw-r--r--archaeological_operations/tests.py3
-rw-r--r--ishtar_common/data_importer.py8
2 files changed, 8 insertions, 3 deletions
diff --git a/archaeological_operations/tests.py b/archaeological_operations/tests.py
index 484e2b259..bbe92b3c8 100644
--- a/archaeological_operations/tests.py
+++ b/archaeological_operations/tests.py
@@ -162,8 +162,11 @@ class ImportOperationTest(TestCase):
sorted([p.section for p in last_parcels]))
last_ope = models.Operation.objects.order_by('-pk').all()[0]
towns_ope = last_ope.towns.all()
+ imported = [imp for acc, imp in impt.get_all_imported()]
for p in last_parcels:
self.assertTrue(p.town in towns_ope)
+ self.assertTrue(p in imported)
+ self.assertEqual(len(imported), len(last_parcels))
self.assertEqual(models.Parcel.objects.get(parcel_number='55',
section='YY').external_id,
'YY55')
diff --git a/ishtar_common/data_importer.py b/ishtar_common/data_importer.py
index 1cdb167bc..2a20c245a 100644
--- a/ishtar_common/data_importer.py
+++ b/ishtar_common/data_importer.py
@@ -727,7 +727,8 @@ class Importer(object):
for k in data['defaults']:
setattr(t_obj, k, data['defaults'][k])
t_obj.save()
- if self.import_instance and hasattr(t_obj, 'imports'):
+ if self.import_instance and hasattr(t_obj, 'imports') \
+ and created:
t_obj.imports.add(self.import_instance)
for formater, val in self._post_processing:
@@ -893,7 +894,7 @@ class Importer(object):
v, created = model.objects.get_or_create(
**v)
if self.import_instance \
- and hasattr(v, 'imports'):
+ and hasattr(v, 'imports') and created:
v.imports.add(self.import_instance)
m2ms.append((attribute, v))
elif hasattr(field_object, 'rel') and field_object.rel and \
@@ -933,7 +934,8 @@ class Importer(object):
dct = create_dict.copy()
dct['defaults'] = defaults
obj, created = cls.objects.get_or_create(**dct)
- if self.import_instance and hasattr(obj, 'imports'):
+ if self.import_instance and hasattr(obj, 'imports') \
+ and created:
obj.imports.add(self.import_instance)
except IntegrityError as e:
raise IntegrityError(e.message)