x/stackalytics
Code Issues Proposed changes

Merge "Implemented error handling of github failures"

Browse Source
This commit is contained in:
Jenkins 2013-08-20 13:42:31 +00:00 committed by Gerrit Code Review
commit 5762531767
2 changed files with 11 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
stackalytics/processor/default_data_processor.py
View File

@ -16,6 +16,7 @@
import hashlib
import json
from github import GithubException
from github import MainClass
from stackalytics.openstack.common import log as logging
@ -54,8 +55,13 @@ def _retrieve_project_list(runtime_storage_inst, project_sources):
for project_source in project_sources:
organization = project_source['organization']
repos = github.get_organization(organization).get_repos()
LOG.debug('Get list of projects for organization %s', organization)
try:
repos = github.get_organization(organization).get_repos()
except GithubException as e:
LOG.exception(e)
LOG.warn('Fail to retrieve list of projects. Keep it unmodified')
return
for repo in repos:
repo_uri = repo.git_url

7
stackalytics/processor/vcs.py
View File

@ -103,6 +103,7 @@ class Git(Vcs):
if not os.path.exists(self.folder):
return {}
LOG.debug('Get release index for repo uri: %s', self.repo['uri'])
os.chdir(self.folder)
if not self.release_index:
for release in self.repo['releases']:
@ -118,7 +119,7 @@ class Git(Vcs):
return self.release_index
def log(self, branch, head_commit_id):
LOG.debug('Parsing git log for repo uri %s' % self.repo['uri'])
LOG.debug('Parsing git log for repo uri %s', self.repo['uri'])
os.chdir(self.folder)
sh.git('checkout', '%s' % branch)
@ -174,7 +175,7 @@ class Git(Vcs):
yield commit
def get_last_id(self, branch):
LOG.debug('Get head commit for repo uri %s' % self.repo['uri'])
LOG.debug('Get head commit for repo uri: %s', self.repo['uri'])
os.chdir(self.folder)
sh.git('checkout', '%s' % branch)
@ -183,7 +184,7 @@ class Git(Vcs):
def get_vcs(repo, sources_root):
uri = repo['uri']
LOG.debug('Factory is asked for VCS uri %s' % uri)
LOG.debug('Factory is asked for VCS uri: %s', uri)
match = re.search(r'\.git$', uri)
if match:
return Git(repo, sources_root)