summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rwxr-xr-xworker_manager6
1 files changed, 5 insertions, 1 deletions
diff --git a/worker_manager b/worker_manager
index 4ee8daf..e5da537 100755
--- a/worker_manager
+++ b/worker_manager
@@ -107,6 +107,7 @@ class WorkerManager(cliapp.Application):
self.sleep_a_little()
def register(self, url, name):
+ logging.info('Registering worker %s to %s', name, url)
register_url = '{}/workers'.format(url)
headers = self.get_auth_headers()
body = {
@@ -114,7 +115,10 @@ class WorkerManager(cliapp.Application):
}
r = requests.post(
register_url, data=body, headers=headers, verify=False)
- logging.info('Created worker: status code %d', r.status_code)
+ if not r.ok:
+ logging.warning('Error registering worker: %d', r.status_code)
+ else:
+ logging.info('Registered worker successfully')
def sleep_a_little(self):
secs = self.settings['sleep']