Fix: if registration fails, abort

1 files changed, 3 insertions, 1 deletions

diff --git a/worker_manager b/worker_manager
index 3552450..ad51619 100755
--- a/worker_manager
+++ b/worker_manager
@@ -131,7 +131,9 @@ class ControllerAPI:
         body = {
             'worker': self._name,
         }
-        self._httpapi.post(url, headers, body)
+        code = self._httpapi.post(url, headers, body)
+        if code not in [200, 201, 409]:
+            raise cliapp.AppException('Failed to register worker')
 
     def get_work(self):
         url = self.url('/work/{}'.format(self._name))