summaryrefslogtreecommitdiff
path: root/worker_manager
diff options
context:
space:
mode:
Diffstat (limited to 'worker_manager')
-rwxr-xr-xworker_manager8
1 files changed, 0 insertions, 8 deletions
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__':