diff --git a/lib/rubyrep/replicators/one_way_replicator.rb b/lib/rubyrep/replicators/one_way_replicator.rb index 14db2e0e..f72e5d42 100644 --- a/lib/rubyrep/replicators/one_way_replicator.rb +++ b/lib/rubyrep/replicators/one_way_replicator.rb @@ -261,7 +261,7 @@ def attempt_update(source_db, diff, remaining_attempts, source_key, target_key) # * +diff+: the current ReplicationDifference instance # * +remaining_attempts+: the number of remaining replication attempts for this difference def attempt_change(action, source_db, target_db, diff, remaining_attempts) - rep_helper.session.send(target_db).transaction { yield } + rep_helper.session.send(target_db).transaction(:requires_new => true) { yield } rep_helper.commit end @@ -336,4 +336,4 @@ def replicate_difference(diff, remaining_attempts = MAX_REPLICATION_ATTEMPTS, pr end end -end \ No newline at end of file +end