ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Resolve AMI region automatically

Browse source
This commit is contained in:
Patrick Wendell 2013-05-08 17:18:21 -07:00
parent f8213aab4b
commit 976e02491e
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
ec2/spark_ec2.py
View file

@ -189,12 +189,14 @@ def get_spark_ami(opts):
if version_prefix != "latest":
print >> stderr, \
"Don't know how to resolve AMI for version: %s" % version_prefix
ami_path = "%s/%s/%s/%s" % (AMI_PREFIX, version_prefix, "us-east", instance_type)
region = "-".join(opts.region.split("-")[:2])
ami_path = "%s/%s/%s/%s" % (AMI_PREFIX, version_prefix, region, instance_type)
try:
ami = urllib2.urlopen(ami_path).read().strip()
print "Spark AMI: " + ami
except:
print >> stderr, "Could not read " + ami_path
print >> stderr, "Could not resolve AMI at: " + ami_path
sys.exit(1)
return ami