From b934eae88fb063497324ed84429568d5e1d3472b Mon Sep 17 00:00:00 2001 From: Kamil Sindi Date: Mon, 20 Jun 2016 11:44:59 -0400 Subject: [PATCH] bugfix with name option --- sparksteps/cluster.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/sparksteps/cluster.py b/sparksteps/cluster.py index 4d484ea..e223d73 100644 --- a/sparksteps/cluster.py +++ b/sparksteps/cluster.py @@ -90,8 +90,8 @@ def emr_config(release_label, master, slave, num_nodes, keep_alive=False, **kw): JobFlowRole='EMR_EC2_DefaultRole', ServiceRole='EMR_DefaultRole', ) - if kw.get('Name'): - config['Name'] = kw.get('Name') + if kw.get('name'): + config['Name'] = kw.get('name') if kw.get('sparksteps_conf', False): config['Configurations'] = SPARKSTEPS_CONF if kw.get('ec2_key'):