diff --git a/lbry/extras/daemon/daemon.py b/lbry/extras/daemon/daemon.py
index 176f04e43..412752f3f 100644
--- a/lbry/extras/daemon/daemon.py
+++ b/lbry/extras/daemon/daemon.py
@@ -9,6 +9,7 @@ import inspect
 import typing
 import random
 import tracemalloc
+from itertools import chain
 from decimal import Decimal
 from urllib.parse import urlencode, quote
 from typing import Callable, Optional, List
@@ -1986,8 +1987,8 @@ class Daemon(metaclass=JSONRPCServerType):
         wallet = self.wallet_manager.get_wallet_or_default(wallet_id)
         wallet_changed = False
         if data is not None:
-            added_accounts = wallet.merge(self.wallet_manager, password, data)
-            for new_account in added_accounts:
+            added_accounts, merged_accounts = wallet.merge(self.wallet_manager, password, data)
+            for new_account in chain(added_accounts, merged_accounts):
                 await new_account.maybe_migrate_certificates()
             if added_accounts and self.ledger.network.is_connected:
                 if blocking:
diff --git a/lbry/wallet/wallet.py b/lbry/wallet/wallet.py
index 7b9ee1bb5..e43e4871f 100644
--- a/lbry/wallet/wallet.py
+++ b/lbry/wallet/wallet.py
@@ -175,9 +175,9 @@ class Wallet:
         return json.loads(decompressed)
 
     def merge(self, manager: 'WalletManager',
-              password: str, data: str) -> List['Account']:
+              password: str, data: str) -> (List['Account'], List['Account']):
         assert not self.is_locked, "Cannot sync apply on a locked wallet."
-        added_accounts = []
+        added_accounts, merged_accounts = [], []
         decrypted_data = self.unpack(password, data)
         self.preferences.merge(decrypted_data.get('preferences', {}))
         for account_dict in decrypted_data['accounts']:
@@ -191,10 +191,11 @@ class Wallet:
                     break
             if local_match is not None:
                 local_match.merge(account_dict)
+                merged_accounts.append(local_match)
             else:
                 new_account = Account.from_dict(ledger, self, account_dict)
                 added_accounts.append(new_account)
-        return added_accounts
+        return added_accounts, merged_accounts
 
     @property
     def is_locked(self) -> bool:
diff --git a/tests/unit/wallet/test_wallet.py b/tests/unit/wallet/test_wallet.py
index e4742696e..fa51bb79c 100644
--- a/tests/unit/wallet/test_wallet.py
+++ b/tests/unit/wallet/test_wallet.py
@@ -209,7 +209,7 @@ class TestWalletCreation(AsyncioTestCase):
         self.assertEqual(len(wallet1.accounts), 1)
         self.assertEqual(wallet1.preferences, {'one': 1, 'conflict': 1})
 
-        added = wallet1.merge(self.manager, 'password', wallet2.pack('password'))
+        added, _ = wallet1.merge(self.manager, 'password', wallet2.pack('password'))
         self.assertEqual(added[0].id, wallet2.default_account.id)
         self.assertEqual(len(wallet1.accounts), 2)
         self.assertEqual(wallet1.accounts[1].id, wallet2.default_account.id)