summaryrefslogtreecommitdiff
path: root/worker_manager
diff options
context:
space:
mode:
authorLars Wirzenius <liw@liw.fi>2017-12-15 18:58:42 +0200
committerLars Wirzenius <liw@liw.fi>2017-12-15 18:58:42 +0200
commitc41e94f209767fedd692ecfa5ddc9e7c96bbe417 (patch)
tree197480f90200b20adb1185e73925b4309b1a03e5 /worker_manager
parenta6c9cfd68b8d97638125fd2c7a4630861e9e5806 (diff)
downloadick2-c41e94f209767fedd692ecfa5ddc9e7c96bbe417.tar.gz
Add: more informative logging of registration
Diffstat (limited to 'worker_manager')
-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']