diff options
author | Lars Wirzenius <liw@liw.fi> | 2017-12-15 18:58:42 +0200 |
---|---|---|
committer | Lars Wirzenius <liw@liw.fi> | 2017-12-15 18:58:42 +0200 |
commit | c41e94f209767fedd692ecfa5ddc9e7c96bbe417 (patch) | |
tree | 197480f90200b20adb1185e73925b4309b1a03e5 /worker_manager | |
parent | a6c9cfd68b8d97638125fd2c7a4630861e9e5806 (diff) | |
download | ick2-c41e94f209767fedd692ecfa5ddc9e7c96bbe417.tar.gz |
Add: more informative logging of registration
Diffstat (limited to 'worker_manager')
-rwxr-xr-x | worker_manager | 6 |
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'] |