summaryrefslogtreecommitdiff
path: root/worker_manager
diff options
context:
space:
mode:
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