forked from LBRYCommunity/lbry-sdk
merge conflicts
This commit is contained in:
parent
c51e344b87
commit
28aa7da349
2 changed files with 12 additions and 7 deletions
|
@ -987,6 +987,11 @@ class LBRYElectrumX(SessionBase):
|
|||
except ConnectionTimeout:
|
||||
self.session_mgr.interrupt_count_metric.inc()
|
||||
raise RPCError(JSONRPC.QUERY_TIMEOUT, 'query timed out')
|
||||
except TooManyClaimSearchParametersError as err:
|
||||
await asyncio.sleep(2)
|
||||
self.logger.warning("Got an invalid query from %s, for %s with more than %d elements.",
|
||||
self.peer_address()[0], err.key, err.limit)
|
||||
return RPCError(1, str(err))
|
||||
finally:
|
||||
self.session_mgr.pending_query_metric.dec()
|
||||
self.session_mgr.executor_time_metric.observe(time.perf_counter() - start)
|
||||
|
|
|
@ -196,13 +196,13 @@ class TestHubDiscovery(CommandTestCase):
|
|||
|
||||
|
||||
class TestStressFlush(CommandTestCase):
|
||||
# async def test_flush_over_66_thousand(self):
|
||||
# history = self.conductor.spv_node.server.db.history
|
||||
# history.flush_count = 66_000
|
||||
# history.flush()
|
||||
# self.assertEqual(history.flush_count, 66_001)
|
||||
# await self.generate(1)
|
||||
# self.assertEqual(history.flush_count, 66_002)
|
||||
# async def test_flush_over_66_thousand(self):
|
||||
# history = self.conductor.spv_node.server.db.history
|
||||
# history.flush_count = 66_000
|
||||
# history.flush()
|
||||
# self.assertEqual(history.flush_count, 66_001)
|
||||
# await self.generate(1)
|
||||
# self.assertEqual(history.flush_count, 66_002)
|
||||
|
||||
async def test_thousands_claim_ids_on_search(self):
|
||||
await self.stream_create()
|
||||
|
|
Loading…
Reference in a new issue