Skip to content

Commit 69f6e22

Browse files
committed
PEP8 fixes
1 parent 2627247 commit 69f6e22

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

ec2/spark_ec2.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -200,6 +200,7 @@ def get_spark_shark_version(opts):
200200
sys.exit(1)
201201
return (version, spark_shark_map[version])
202202

203+
203204
# Attempt to resolve an appropriate AMI given the architecture and
204205
# region of the request.
205206
def get_spark_ami(opts):
@@ -421,11 +422,11 @@ def launch_cluster(conn, opts, cluster_name):
421422
# Give the instances descriptive names
422423
for master in master_nodes:
423424
master.add_tag(
424-
key='Name',
425+
key='Name',
425426
value='spark-{cn}-master-{iid}'.format(cn=cluster_name, iid=master.id))
426427
for slave in slave_nodes:
427428
slave.add_tag(
428-
key='Name',
429+
key='Name',
429430
value='spark-{cn}-slave-{iid}'.format(cn=cluster_name, iid=slave.id))
430431

431432
# Return all the instances

0 commit comments

Comments
 (0)