Commit 53010872 by Feanil Patel

Pass the mongo uri to abbey.

parent 3dfb7023
...@@ -83,7 +83,8 @@ def uri_from(doc_store_config): ...@@ -83,7 +83,8 @@ def uri_from(doc_store_config):
def prepare_release(args): def prepare_release(args):
config = yaml.safe_load(open(args.config)) config = yaml.safe_load(open(args.config))
client = MongoClient(uri_from(config['DOC_STORE_CONFIG'])) mongo_uri = uri_from(config['DOC_STORE_CONFIG'])
client = MongoClient(mongo_uri)
db = client[config['DOC_STORE_CONFIG']['db']] db = client[config['DOC_STORE_CONFIG']['db']]
# Get configuration repo versions # Get configuration repo versions
...@@ -152,7 +153,8 @@ def prepare_release(args): ...@@ -152,7 +153,8 @@ def prepare_release(args):
release['plays'] = all_plays release['plays'] = all_plays
release_coll.insert(release) release_coll.insert(release)
# All plays that need new AMIs have been updated. # All plays that need new AMIs have been updated.
notify_abbey(config['abbey_url'], config['abbey_token'], args.deployment, all_plays, args.release_id) notify_abbey(config['abbey_url'], config['abbey_token'], args.deployment,
all_plays, args.release_id, mongo_uri)
def ami_for(db, env, deployment, play, configuration, def ami_for(db, env, deployment, play, configuration,
configuration_secure, ansible_vars): configuration_secure, ansible_vars):
...@@ -169,7 +171,7 @@ def ami_for(db, env, deployment, play, configuration, ...@@ -169,7 +171,7 @@ def ami_for(db, env, deployment, play, configuration,
return db.amis.find_one(ami_signature) return db.amis.find_one(ami_signature)
import requests import requests
def notify_abbey(abbey_url, abbey_token, deployment, all_plays, release_id): def notify_abbey(abbey_url, abbey_token, deployment, all_plays, release_id, mongo_uri):
for play_name, play in all_plays.items(): for play_name, play in all_plays.items():
for env, ami in play['amis'].items(): for env, ami in play['amis'].items():
if ami is None: if ami is None:
...@@ -179,6 +181,7 @@ def notify_abbey(abbey_url, abbey_token, deployment, all_plays, release_id): ...@@ -179,6 +181,7 @@ def notify_abbey(abbey_url, abbey_token, deployment, all_plays, release_id):
params.append({ 'name': 'environment', 'value': env}) params.append({ 'name': 'environment', 'value': env})
params.append({ 'name': 'vars', 'value': yaml.dump(play['vars'], default_flow_style=False)}) params.append({ 'name': 'vars', 'value': yaml.dump(play['vars'], default_flow_style=False)})
params.append({ 'name': 'release_id', 'value': release_id}) params.append({ 'name': 'release_id', 'value': release_id})
params.append({ 'name': 'mongo_uri', 'value': mongo_uri})
build_params = {'parameter': params} build_params = {'parameter': params}
log.info("Need ami for {}".format(pformat(build_params))) log.info("Need ami for {}".format(pformat(build_params)))
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment