from autotest_lib.frontend.shared import rest_client
from autotest_lib.server import frontend

planner_rpc = frontend.Planner()
afe_rest = rest_client.Resource.load('http://%(server)s/afe/server/resources')


label = afe_rest.labels.get(name='%(label_name)s').members[0].get()

def run(machine):
    hostname = hosts.create_host(machine).hostname
    host = afe_rest.hosts.get(hostname=hostname).members[0]
    label.hosts.post({'host': host})

job.parallel_simple(run, machines)

planner_rpc.run('modify_plan', id=%(plan_id)d, initialized=True)