frontend/planner/set_atomic_group_control.srv

   1 from autotest_lib.frontend.shared import rest_client
   2 from autotest_lib.server import frontend
   3
   4 planner_rpc = frontend.Planner()
   5 afe_rest = rest_client.Resource.load('http://%(server)s/afe/server/resources')
   6
   7
   8 label = afe_rest.labels.get(name='%(label_name)s').members[0].get()
   9
  10 def run(machine):
  11     hostname = hosts.create_host(machine).hostname
  12     host = afe_rest.hosts.get(hostname=hostname).members[0]
  13     label.hosts.post({'host': host})
  14
  15 job.parallel_simple(run, machines)
  16
  17 planner_rpc.run('modify_plan', id=%(plan_id)d, initialized=True)