'Commits the current transaction.
Must be preceded by a start_transaction call.'

def commit_transaction(self):

    if self.dry_run:
        return
    transaction.commit(using=self.db_alias)
    transaction.leave_transaction_management(using=self.db_alias)
