Madiator2011/lbry-sdk
1
0
Fork 0
forked from LBRYCommunity/lbry-sdk
Code Pull requests Activity

remove assert causing failures in console.py

Browse source
This commit is contained in:
Lex Berezhny 2020-07-22 18:07:18 -04:00
parent 8100efb48c
commit 412ace1c6f
3 changed files with 1 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
lbry/cli.py
View file

@ -221,14 +221,11 @@ def main(argv=None):
if args.help: if args.help:
args.start_parser.print_help() args.start_parser.print_help()
elif args.full_node: elif args.full_node:
print('Instantiating FullNode')
service = FullNode(Ledger(conf)) service = FullNode(Ledger(conf))
if conf.console == "advanced": if conf.console == "advanced":
console = AdvancedConsole(service) console = AdvancedConsole(service)
else: else:
print('Instantiating BasicConsole')
console = BasicConsole(service) console = BasicConsole(service)
print('Daemon(service, console).run()')
return Daemon(service, console).run() return Daemon(service, console).run()
else: else:
print('Only `start --full-node` is currently supported.') print('Only `start --full-node` is currently supported.')

2
lbry/console.py
View file

@ -394,7 +394,7 @@ class Advanced(Basic):
bar_name = f"{name}#{d['id']}" bar_name = f"{name}#{d['id']}"
bar = self.bars.get(bar_name) bar = self.bars.get(bar_name)
if bar is None: if bar is None:
assert d['done'][0] == 0 #assert d['done'][0] == 0
label = d.get('label', name[-11:]) label = d.get('label', name[-11:])
self.get_or_create_bar( self.get_or_create_bar(
f"{name}#{d['id']}", label, d['units'], d['total'], f"{name}#{d['id']}", label, d['units'], d['total'],

7
lbry/service/daemon.py
View file

@ -96,9 +96,7 @@ class Daemon:
pass # Not implemented on Windows pass # Not implemented on Windows
try: try:
print('loop.run_until_complete(self.start())')
loop.run_until_complete(self.start()) loop.run_until_complete(self.start())
print('loop.run_forever()')
loop.run_forever() loop.run_forever()
except (GracefulExit, KeyboardInterrupt, asyncio.CancelledError): except (GracefulExit, KeyboardInterrupt, asyncio.CancelledError):
pass pass
@ -110,15 +108,10 @@ class Daemon:
loop.run_until_complete(loop.shutdown_asyncgens()) loop.run_until_complete(loop.shutdown_asyncgens())
async def start(self): async def start(self):
print('self.console.starting()')
self.console.starting() self.console.starting()
print('await self.runner.setup()')
await self.runner.setup() await self.runner.setup()
print('TCPSite(self.runner, self.conf.api_host, self.conf.api_port)')
site = TCPSite(self.runner, self.conf.api_host, self.conf.api_port) site = TCPSite(self.runner, self.conf.api_host, self.conf.api_port)
print('await site.start()')
await site.start() await site.start()
print('await self.service.start()')
await self.service.start() await self.service.start()
async def stop(self): async def stop(self):