Add an 'owner' param to the Test Planner execution engine and the REST
client
Signed-off-by: James Ren <jamesren@google.com>
git-svn-id: http://test.kernel.org/svn/autotest/trunk@4431 592f7852-d20e-0410-864c-8624ca9c26a4
diff --git a/frontend/planner/rpc_utils.py b/frontend/planner/rpc_utils.py
index 4c93444..7195921 100644
--- a/frontend/planner/rpc_utils.py
+++ b/frontend/planner/rpc_utils.py
@@ -38,9 +38,11 @@
"""
timeout = global_config.global_config.get_config_value(
'PLANNER', 'execution_engine_timeout')
- control = _get_execution_engine_control(server=SERVER,
- plan_id=plan.id,
- label_name=label.name)
+ control = _get_execution_engine_control(
+ server=SERVER,
+ plan_id=plan.id,
+ label_name=label.name,
+ owner=afe_models.User.current_user().login)
options = {'name': plan.name + '_execution_engine',
'priority': afe_models.Job.Priority.MEDIUM,
'control_file': control,
@@ -57,13 +59,14 @@
job.queue(hosts=())
-def _get_execution_engine_control(server, plan_id, label_name):
+def _get_execution_engine_control(server, plan_id, label_name, owner):
"""
Gets the control file to run the execution engine
"""
control = lazy_load(os.path.join(os.path.dirname(__file__),
'execution_engine_control.srv'))
- return control % dict(server=server, plan_id=plan_id, label_name=label_name)
+ return control % dict(server=server, plan_id=plan_id,
+ label_name=label_name, owner=owner)
def lazy_load(path):