Skip to content

Commit

Permalink
PEP8 fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
nchammas committed Jun 11, 2014
1 parent 2627247 commit 69f6e22
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions ec2/spark_ec2.py
Original file line number Diff line number Diff line change
Expand Up @@ -200,6 +200,7 @@ def get_spark_shark_version(opts):
sys.exit(1)
return (version, spark_shark_map[version])


# Attempt to resolve an appropriate AMI given the architecture and
# region of the request.
def get_spark_ami(opts):
Expand Down Expand Up @@ -421,11 +422,11 @@ def launch_cluster(conn, opts, cluster_name):
# Give the instances descriptive names
for master in master_nodes:
master.add_tag(
key='Name',
key='Name',
value='spark-{cn}-master-{iid}'.format(cn=cluster_name, iid=master.id))
for slave in slave_nodes:
slave.add_tag(
key='Name',
key='Name',
value='spark-{cn}-slave-{iid}'.format(cn=cluster_name, iid=slave.id))

# Return all the instances
Expand Down

0 comments on commit 69f6e22

Please sign in to comment.