Some of this is probably already done but dual write modified some of this logic and wasn't necessarily focused on the migrator.

The other aspect we need is to make sure the migrator is writing to the outbox (see OutboxReplicator)