summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorLars Wirzenius <liw@liw.fi>2018-03-30 14:14:49 +0300
committerLars Wirzenius <liw@liw.fi>2018-03-30 14:16:08 +0300
commit770bc9e29739e602ac95488d3e90b1480e55a936 (patch)
tree36f6b4b26f836e089cf075c31ff93e47eadf73c5
parent7951e2ee4f9bd2a2780488720e0b8c625e43e5d0 (diff)
downloadick2-770bc9e29739e602ac95488d3e90b1480e55a936.tar.gz
Drop: much debug logging
-rw-r--r--ick2/actions.py10
-rw-r--r--ick2/client.py11
-rwxr-xr-xworker_manager8
3 files changed, 0 insertions, 29 deletions
diff --git a/ick2/actions.py b/ick2/actions.py
index 632739a..fd0d282 100644
--- a/ick2/actions.py
+++ b/ick2/actions.py
@@ -15,7 +15,6 @@
import base64
import json
-import logging
import os
import tempfile
@@ -209,9 +208,6 @@ class CreateWorkspaceAction(Action):
pass
def execute(self, params, step):
- logging.debug('CreateWorkspaceAction: params=%r', params)
- logging.debug('CreateWorkspaceAction: step=%r', step)
-
env = self.get_env()
workspace = env.get_workspace_directory()
self._env.report(0, 'Created workspace %s\n' % workspace)
@@ -232,12 +228,6 @@ class ArchiveWorkspaceAction(Action): # pragma: no cover
url = self.get_blob_upload_url(blob_name)
headers = self.get_authz_headers()
- logging.debug('ArchiveWorkspaceAction: url=%r', url)
- logging.debug('ArchiveWorkspaceAction: headers=%r', headers)
-
- assert url is not None
- assert headers is not None
-
fd, tarball = tempfile.mkstemp()
os.close(fd)
tar = ['sudo', 'tar', '-zcf', tarball, '-C', dirname, '.']
diff --git a/ick2/client.py b/ick2/client.py
index 99b8487..5468c7f 100644
--- a/ick2/client.py
+++ b/ick2/client.py
@@ -92,16 +92,7 @@ class HttpAPI:
headers = {}
headers.update(self._get_authorization_headers())
- logging.debug('request: func=%r', func)
- logging.debug('request: url=%r', url)
- for h in headers:
- logging.debug('request: %s: %s', h, headers[h])
- logging.debug('request: kwargs=%r', kwargs)
-
r = func(url, headers=headers, verify=False, **kwargs)
- logging.debug('response: status_code=%r', r.status_code)
- logging.debug('response: content=%r', r.content)
-
if not r.ok:
raise HttpError(r.status_code)
return r
@@ -182,8 +173,6 @@ class Reporter: # pragma: no cover
result['exit_code'] = exit_code
result['stdout'] = self.make_string(stdout)
result['stderr'] = self.make_string(stderr)
- for key in result:
- logging.debug('Reporter: result[%r]=%r', key, result[key])
self._api.report_work(result)
def make_string(self, thing):
diff --git a/worker_manager b/worker_manager
index ad01fd7..748fdd6 100755
--- a/worker_manager
+++ b/worker_manager
@@ -230,23 +230,15 @@ class Worker:
self._systree = systree
def do_work(self, work):
- logging.debug('Doing work: %r', work)
project_name = work['project']
step = work.get('step', {})
- logging.debug('Doing work: step=%r', step)
params = work.get('parameters', {})
- logging.debug('Doing work: params=%r', params)
reporter = ick2.Reporter(self._api, work)
- logging.debug('Doing work: reporter=%r', reporter)
af = ick2.ActionFactory(self._systree, self._workspace, reporter)
- logging.debug('Doing work: af=%r', af)
af.set_token(self._api.get_token())
af.set_blob_url_func(self._api.get_blob_upload_url)
action = af.create_action(step, project_name)
- logging.debug('Doing work: action=%r', action)
exit_code = action.execute(params, step)
- logging.debug('Action finished: exit_code=%r', exit_code)
- logging.debug('Finished work: %r', work)
if __name__ == '__main__':