worker: publish new status upon worker crash

2018-07-14 22:30:29 -03:00 · 2018-07-14 22:30:29 -03:00 · e3a3e1b77b
parent 8d8f38b5a1
commit e3a3e1b77b
1 changed files with 1 additions and 0 deletions
--- a/elstat/worker.py
+++ b/elstat/worker.py
@ -67,6 +67,7 @@ class ServiceWorker:
            self.log.exception('fail on work loop, retrying')
            try:
                self.manager.state[self.name]['status'] = False
+                self.manager.publish(f'status:{self.name}', False)
            except KeyError:
                pass
            await self._work_loop()