wip

lbry/testcase.py

@@ -316,7 +316,7 @@ async def stop(self):
 
 class CommandTestCase(IntegrationTestCase):
 
-    VERBOSITY = logging.WARN
+    VERBOSITY = logging.INFO
     blob_lru_cache_size = 0
 
     def __init__(self, *args, **kwargs):
@@ -449,7 +449,9 @@ def get_all_addresses(tx):
     async def generate(self, blocks):
         """ Ask lbrycrd to generate some blocks and wait until ledger has them. """
         await self.blockchain.generate(blocks)
+        logging.warning("waiting height %s", self.blockchain.block_expected)
         await self.ledger.on_header.where(self.blockchain.is_expected_block)
+        logging.warning("got header %s", self.blockchain.block_expected)
 
     async def blockchain_claim_name(self, name: str, value: str, amount: str, confirm=True):
         txid = await self.blockchain._cli_cmnd('claimname', name, value, amount)

lbry/wallet/ledger.py

@@ -717,6 +717,7 @@ async def wait(self, tx: Transaction, height=-1, timeout=1):
                 addresses.add(self.hash160_to_address(txo.pubkey_hash))
         start = int(time.perf_counter())
         while timeout and (int(time.perf_counter()) - start) <= timeout:
+            log.warning('wait %s %s %s %s', tx, height, addresses, timeout)
             if await self._wait_round(tx, height, addresses):
                 return
         raise asyncio.TimeoutError('Timed out waiting for transaction.')