|
@@ -25,12 +25,16 @@ summary_item = sql.Table(
|
|
|
|
|
|
|
|
|
|
|
|
|
class SummaryV2(object):
|
|
class SummaryV2(object):
|
|
|
- def __init__(self, engine, summary_id):
|
|
|
|
|
|
|
+ def __init__(self, engine, summary_id, errorlogs=None):
|
|
|
self.summary_id = summary_id
|
|
self.summary_id = summary_id
|
|
|
self._engine = engine
|
|
self._engine = engine
|
|
|
|
|
+ self.errorlogs = errorlogs
|
|
|
|
|
|
|
|
def handle_build_result(self, exc, repo, version, img_id, build_result):
|
|
def handle_build_result(self, exc, repo, version, img_id, build_result):
|
|
|
c = self._engine.connect()
|
|
c = self._engine.connect()
|
|
|
|
|
+ if exc and self.errorlogs:
|
|
|
|
|
+ with open('{2}/{0}.{1}.error.log'.format(repo.name, version[1], self.errorlogs)) as f:
|
|
|
|
|
+ f.write(build_result)
|
|
|
ins = summary_item.insert().values(
|
|
ins = summary_item.insert().values(
|
|
|
repo_name=repo.name,
|
|
repo_name=repo.name,
|
|
|
exception=str(exc),
|
|
exception=str(exc),
|
|
@@ -72,14 +76,14 @@ class DbManager(object):
|
|
|
c.execute(ins)
|
|
c.execute(ins)
|
|
|
return summary_id
|
|
return summary_id
|
|
|
|
|
|
|
|
- def new_summary(self):
|
|
|
|
|
|
|
+ def new_summary(self, errorlogs=None):
|
|
|
c = self._engine.connect()
|
|
c = self._engine.connect()
|
|
|
ins = summary.insert().values(
|
|
ins = summary.insert().values(
|
|
|
result=True, build_date=str(datetime.datetime.now())
|
|
result=True, build_date=str(datetime.datetime.now())
|
|
|
)
|
|
)
|
|
|
r = c.execute(ins)
|
|
r = c.execute(ins)
|
|
|
summary_id = r.inserted_primary_key[0]
|
|
summary_id = r.inserted_primary_key[0]
|
|
|
- return SummaryV2(self._engine, summary_id)
|
|
|
|
|
|
|
+ return SummaryV2(self._engine, summary_id, errorlogs)
|
|
|
|
|
|
|
|
def latest_status(self):
|
|
def latest_status(self):
|
|
|
c = self._engine.connect()
|
|
c = self._engine.connect()
|