summaryrefslogtreecommitdiff
path: root/worker_manager
diff options
context:
space:
mode:
authorLars Wirzenius <liw@liw.fi>2017-11-29 21:19:15 +0100
committerLars Wirzenius <liw@liw.fi>2017-11-29 21:47:56 +0100
commit491a6a196148fd5f5e7f6670edd72dec7875d382 (patch)
treed33708bbbafe245b5f654e7b0544bafdc7b83f15 /worker_manager
parent4dbd616221490d7e11cddff561941057bd1e1273 (diff)
downloadick2-491a6a196148fd5f5e7f6670edd72dec7875d382.tar.gz
Add: reduce logging when nothing happens
Filling the disk otherwise
Diffstat (limited to 'worker_manager')
-rwxr-xr-xworker_manager6
1 files changed, 2 insertions, 4 deletions
diff --git a/worker_manager b/worker_manager
index 15a6ef8..bf7f14e 100755
--- a/worker_manager
+++ b/worker_manager
@@ -103,23 +103,21 @@ class WorkerManager(cliapp.Application):
elif work:
self.do_work(url, name, work, self.settings['workspace'])
else:
- self.show_msg('Nothing to do')
self.sleep_a_little()
def sleep_a_little(self):
secs = self.settings['sleep']
- self.show_msg('Sleeping for {} seconds'.format(secs))
time.sleep(secs)
def get_work(self, url, name):
get_work_url = '{}/work/{}'.format(url, name)
- self.show_msg('Getting work from {}'.format(get_work_url))
headers = self.get_auth_headers()
r = requests.get(get_work_url, headers=headers, verify=False)
if r.status_code != 200 or not r.text:
return None
work = r.json()
- self.show_json('Response:', work)
+ if work:
+ self.show_json('Response:', work)
return work
def get_auth_headers(self):