Theoretical handling of system task updates; stdout straight to logger

This commit is contained in:
James Barnsley
2020-01-17 23:14:43 +13:00
parent 0e15a8745e
commit 169396042a
11 changed files with 7788 additions and 54 deletions

View File

@ -467,12 +467,17 @@ class IrisCore(pykka.ThreadingActor):
else:
return response
def restart_callback(self, response, error):
def restart_callback(self, response, error, update):
if error:
self.broadcast(data={
'method': "restart_error",
'params': error
})
elif update:
self.broadcast(data={
'method': "restart_update",
'params': update
})
else:
self.broadcast(data={
'method': "restart_finished",
@ -502,12 +507,17 @@ class IrisCore(pykka.ThreadingActor):
else:
return response
def upgrade_callback(self, response, error):
def upgrade_callback(self, response, error, update):
if error:
self.broadcast(data={
'method': "upgrade_error",
'params': error
})
elif update:
self.broadcast(data={
'method': "upgrade_update",
'params': update
})
else:
self.broadcast(data={
'method': "upgrade_finished",
@ -538,12 +548,17 @@ class IrisCore(pykka.ThreadingActor):
else:
return response
def local_scan_callback(self, response, error):
def local_scan_callback(self, response, error, update):
if error:
self.broadcast(data={
'method': "local_scan_error",
'params': error
})
elif update:
self.broadcast(data={
'method': "local_scan_update",
'params': update
})
else:
self.broadcast(data={
'method': "local_scan_finished",