From bc4075e2ed2128d2191e94f461b0efdda7f88b67 Mon Sep 17 00:00:00 2001 From: Jack Robison Date: Wed, 25 Mar 2020 17:48:05 -0400 Subject: [PATCH] create_task instead of ensure_future --- lbry/wallet/ledger.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/lbry/wallet/ledger.py b/lbry/wallet/ledger.py index 468e38307..cfd89b6ee 100644 --- a/lbry/wallet/ledger.py +++ b/lbry/wallet/ledger.py @@ -497,14 +497,15 @@ class Ledger(metaclass=LedgerRegistry): if not we_need: return True - cache_tasks: List[asyncio.Future[Transaction]] = [] + cache_tasks: List[asyncio.Task[Transaction]] = [] synced_history = StringIO() + loop = asyncio.get_running_loop() for i, (txid, remote_height) in enumerate(remote_history): if i < len(local_history) and local_history[i] == (txid, remote_height) and not cache_tasks: synced_history.write(f'{txid}:{remote_height}:') else: check_local = (txid, remote_height) not in we_need - cache_tasks.append(asyncio.ensure_future( + cache_tasks.append(loop.create_task( self.cache_transaction(txid, remote_height, check_local=check_local) ))