Commit 15acb811 by Feanil Patel

Remove cruft regarding flip repos.

We never used this function.
parent ca797539
...@@ -9,7 +9,7 @@ from git import Repo ...@@ -9,7 +9,7 @@ from git import Repo
from os import path from os import path
from pprint import pformat from pprint import pformat
from pymongo import MongoClient, DESCENDING from pymongo import MongoClient, DESCENDING
from stage_release import flip_repos, uri_from from stage_release import uri_from
def releases(repo): def releases(repo):
""" """
...@@ -72,7 +72,6 @@ if __name__ == "__main__": ...@@ -72,7 +72,6 @@ if __name__ == "__main__":
data['last_check'] = datetime.utcnow() data['last_check'] = datetime.utcnow()
all_plays = flip_repos(config['repos'])
# Find plays that are affected by this repo. # Find plays that are affected by this repo.
repos_with_changes = {} repos_with_changes = {}
for repo in config['repos']: for repo in config['repos']:
......
...@@ -81,20 +81,6 @@ def uri_from(doc_store_config): ...@@ -81,20 +81,6 @@ def uri_from(doc_store_config):
hosts=",".join(host_uris), hosts=",".join(host_uris),
db=doc_store_config['db']) db=doc_store_config['db'])
def flip_repos(repos):
""" Take a dict mapping repos to plays and give a dict mapping plays to repos. """
all_plays = {}
for repo in repos:
plays = repos[repo]['plays']
for play in plays:
if play in all_plays:
all_plays[play]['repos'].append(repo)
else:
all_plays[play] = {}
all_plays[play]['repos'] = [repo]
return all_plays
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'])) client = MongoClient(uri_from(config['DOC_STORE_CONFIG']))
...@@ -109,8 +95,6 @@ def prepare_release(args): ...@@ -109,8 +95,6 @@ def prepare_release(args):
update_repos = { item[0]:item[1] for item in var_array } update_repos = { item[0]:item[1] for item in var_array }
log.info("Update repos: {}".format(pformat(update_repos))) log.info("Update repos: {}".format(pformat(update_repos)))
all_plays = flip_repos(config['repos'])
release = {} release = {}
now = datetime.utcnow() now = datetime.utcnow()
release['_id'] = args.release_id release['_id'] = args.release_id
...@@ -188,7 +172,6 @@ import requests ...@@ -188,7 +172,6 @@ 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):
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():
log.info("{}:{}".format(env,ami))
if ami is None: if ami is None:
params = [] params = []
params.append({ 'name': 'play', 'value': play_name}) params.append({ 'name': 'play', 'value': play_name})
......
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