logging
This commit is contained in:
parent
d80c671cf2
commit
1116c7f29e
2 changed files with 5 additions and 0 deletions
|
@ -439,10 +439,13 @@ class Daemon(metaclass=JSONRPCServerType):
|
||||||
await self.component_manager.stop()
|
await self.component_manager.stop()
|
||||||
else:
|
else:
|
||||||
self.component_startup_task.cancel()
|
self.component_startup_task.cancel()
|
||||||
|
log.info("stopped api components")
|
||||||
await self.runner.shutdown()
|
await self.runner.shutdown()
|
||||||
await self.runner.cleanup()
|
await self.runner.cleanup()
|
||||||
|
log.info("stopped api server")
|
||||||
if self.analytics_manager.is_started:
|
if self.analytics_manager.is_started:
|
||||||
self.analytics_manager.stop()
|
self.analytics_manager.stop()
|
||||||
|
log.info("finished shutting down")
|
||||||
|
|
||||||
async def handle_old_jsonrpc(self, request):
|
async def handle_old_jsonrpc(self, request):
|
||||||
data = await request.json()
|
data = await request.json()
|
||||||
|
|
|
@ -355,6 +355,8 @@ class ManagedStream:
|
||||||
self.download_id, self.claim_name, self.sd_hash
|
self.download_id, self.claim_name, self.sd_hash
|
||||||
))
|
))
|
||||||
self.finished_writing.set()
|
self.finished_writing.set()
|
||||||
|
log.info("finished saving file for lbry://%s#%s (sd hash %s...) -> %s", self.claim_name, self.claim_id,
|
||||||
|
self.sd_hash[:6])
|
||||||
except Exception as err:
|
except Exception as err:
|
||||||
if os.path.isfile(output_path):
|
if os.path.isfile(output_path):
|
||||||
log.warning("removing incomplete download %s for %s", output_path, self.sd_hash)
|
log.warning("removing incomplete download %s for %s", output_path, self.sd_hash)
|
||||||
|
|
Loading…
Reference in a new issue