Add support for an --image flag to atest.

cli/job.py

 #
 # Copyright 2008 Google Inc. All Rights Reserved.
 
 """
 The job module contains the objects and methods used to
 manage jobs in Autotest.
 
 The valid actions are:
 list:    lists job(s)
 create:  create a job
@@ skipping 344 matching lines @@
     """atest job create [--priority <Low|Medium|High|Urgent>]
     [--synch_count] [--control-file </path/to/cfile>]
     [--on-server] [--test <test1,test2>] [--kernel <http://kernel>]
     [--mlist </path/to/machinelist>] [--machine <host1 host2 host3>]
     [--labels <list of labels of machines to run on>]
     [--reboot_before <option>] [--reboot_after <option>]
     [--noverify] [--timeout <timeout>] [--max_runtime <max runtime>]
     [--one-time-hosts <hosts>] [--email <email>]
     [--dependencies <labels this job is dependent on>]
     [--atomic_group <atomic group name>] [--parse-failed-repair <option>]
+    [--image <http://path/to/image>]
     job_name
 
     Creating a job is rather different from the other create operations,
     so it only uses the __init__() and output() from its superclass.
     """
     op_action = 'create'
 
     def __init__(self):
         super(job_create, self).__init__()
         self.ctrl_file_data = {}
@@ skipping 41 matching lines @@
                                type='choice',
                                choices=('true', 'false'))
         self.parser.add_option('-n', '--noverify',
                                help='Do not run verify for job',
                                default=False, action='store_true')
         self.parser.add_option('-o', '--timeout', help='Job timeout in hours.',
                                metavar='TIMEOUT')
         self.parser.add_option('--max_runtime',
                                help='Job maximum runtime in hours')
 
+        self.parser.add_option('-i', '--image',
+                               help='OS image to install before running the '
+                                    'test.')
+
 
     @staticmethod
     def _get_kernel_data(kernel_list, cmdline):
         # the RPC supports cmdline per kernel version in a dictionary
         kernels = []
         for version in re.split(r'[, ]+', kernel_list):
             if not version:
                 continue
             kernel_info = {'version': version}
             if cmdline:
@@ skipping 38 matching lines @@
             else:
                 self.data['control_file'] = control_file_data
         if options.test:
             if options.server:
                 self.invalid_syntax('If you specify tests, then the '
                                     'client/server setting is implicit and '
                                     'cannot be overriden.')
             tests = [t.strip() for t in options.test.split(',') if t.strip()]
             self.ctrl_file_data['tests'] = tests
 
+        if options.image:
+            self.data['image'] = options.image
 
         if options.reboot_before:
             self.data['reboot_before'] = options.reboot_before.capitalize()
         if options.reboot_after:
             self.data['reboot_after'] = options.reboot_after.capitalize()
         if options.parse_failed_repair:
             self.data['parse_failed_repair'] = (
                 options.parse_failed_repair == 'true')
         if options.noverify:
             self.data['run_verify'] = False
@@ skipping 136 matching lines @@
 
 
     def execute(self):
         data = {'job__id__in': self.jobids}
         self.execute_rpc(op='abort_host_queue_entries', **data)
         print 'Aborting jobs: %s' % ', '.join(self.jobids)
 
 
     def get_items(self):
         return self.jobids