summaryrefslogtreecommitdiff
path: root/worker_manager
diff options
context:
space:
mode:
authorLars Wirzenius <liw@liw.fi>2018-01-13 15:20:37 +0200
committerLars Wirzenius <liw@liw.fi>2018-01-14 22:23:48 +0200
commiteaf8f8bc1957079f5a4009074d8bd81e28638e7c (patch)
treed6ae7b85918886cfee5dbac073cbe8ba9247dbc3 /worker_manager
parentefba85dcfa234b40160864e6eeddd472fb9853a9 (diff)
downloadick2-eaf8f8bc1957079f5a4009074d8bd81e28638e7c.tar.gz
Add: populate_systree action to worker-manager
Diffstat (limited to 'worker_manager')
-rwxr-xr-xworker_manager5
1 files changed, 3 insertions, 2 deletions
diff --git a/worker_manager b/worker_manager
index bdd982c..a7a2b10 100755
--- a/worker_manager
+++ b/worker_manager
@@ -302,6 +302,8 @@ class Worker:
return DebootstrapWorker
elif 'archive' in step:
return WorkspaceArchiver
+ elif step.get('action') == 'populate_systree':
+ return SystreePopulator
elif step.get('action') == 'create_workspace':
return WorkspaceCleaner
logging.warning('Cannot find worker for %s', step)
@@ -443,8 +445,7 @@ class SystreePopulator(WorkerBase):
systree_dir = '/var/lib/ick/systree'
def do(self, work):
- params = work.get('parameters', {})
- systree_name = params.get('systree_name')
+ systree_name = work.get('systree_name')
if not systree_name:
self.report(b'No systree_name parameter, no systree population')
return 0