openstack/python-saharaclient
Code Issues Proposed changes

Add job-create to CLI

Browse Source 
Change-Id: I441fe2f488fa82bb3d0df50876929f22b71cd666
Implements: blueprint python-savannaclient-cli
This commit is contained in:
Matthew Farrellee
2014-01-27 16:05:06 -05:00
parent 8abdb23f90
commit ad8d03c013
1 changed files with 40 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

46
savannaclient/api/shell.py
View File

@@ -702,12 +702,11 @@ def do_job_template_delete(cs, args):
#
# job-show --name <name>|--id <id>
#
# TODO(mattf): job-create --name <name> --job-template <id>
# --input-data <id>
# --output-data <id>
# --cluster-template <id>
# NB: Optional job_configs
# NB: POST /jobs/{job_template_id}/execute
# job-create --job-template <id> --cluster <id>
# [--input-data <id>] [--output-data <id>]
# [--param <name=value>]
# [--arg <arg>]
# [--config <name=value>]
#
# job-delete --name <name>|--id <id>
#
@@ -732,6 +731,41 @@ def do_job_show(cs, args):
_show_job(cs.job_executions.get(args.id))
@utils.arg('--job-template',
required=True,
help='Id of the job template to run')
@utils.arg('--cluster',
required=True,
help='Id of the cluster to run the job in')
@utils.arg('--input-data',
default=None,
help='Id of the input data source')
@utils.arg('--output-data',
default=None,
help='Id of the output data source')
@utils.arg('--param',
metavar='name=value',
action='append',
default=[],
help='Params to add to the job, repeatable')
@utils.arg('--arg',
action='append',
default=[],
help='Args to add to the job, repeatable')
@utils.arg('--config',
metavar='name=value',
action='append',
default=[],
help='Config parameters to add to the job, repeatable')
def do_job_create(cs, args):
_convert = lambda ls: dict(map(lambda i: i.split('=', 1), ls))
_show_job(cs.job_executions.create(args.job_template, args.cluster,
args.input_data, args.output_data,
{'params': _convert(args.param),
'args': dict(zip(args.arg, args.arg)),
'configs': _convert(args.config)}))
@utils.arg('--id',
required=True,
help='Id of a job')