diff --git a/hshetl/entities.py b/hshetl/entities.py index 5a5543774c678f5f5f09d85208a5daf53eb4e9e7..681fa8ba92b93fe15b2f7f4cbb60a8d7c870449a 100644 --- a/hshetl/entities.py +++ b/hshetl/entities.py @@ -100,7 +100,9 @@ class Entity(AbstractRepository): container_identifier = self._hash(container_fields) if container_identifier in container: - container.container_collide(Record(join_identifier, self.properties, self.itervalues())) + rec = Record(join_identifier, self.properties, self.itervalues()) + rec.load(container_fields, mapped_record, container) + container.container_collide(rec) return if self.record_repository.has(join_identifier):