bugfix with name option

jwplayer · Jun 20, 2016 · b934eae · b934eae
1 parent d3b8943
commit b934eae
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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'):