# Store the time
self._set_attribute_now("started_at")
- async def finished(self, success, packages=None, message=None, log=None):
+ async def finished(self, success, packages=None, message=None, logfile=None):
"""
Called when this job has finished
"""
self._set_attribute_now("finished_at")
# Import log
- if log:
- await self._import_log(log)
+ if logfile:
+ await self._import_logfile(logfile)
# Import packages
if success and packages:
# Notify the owner
if self.build.owner:
- # Tail the log
- log = await self.tail_log(100)
-
# Send an email
self.build.owner.send_email(
- "jobs/messages/failed.txt", job=self, build=self.build, log=log,
+ "jobs/messages/failed.txt",
+ job=self,
+ build=self.build,
+ log=await self.tail_log(100),
)
# Propagate any changes to the build
# Return all lines
return q
- async def _import_log(self, upload):
+ async def _import_logfile(self, upload):
# Create some destination path
path = self.backend.path(
"logs",
success = self.get_argument_bool("success")
# Fetch the log
- log = self.get_argument_upload("log")
+ logfile = self.get_argument_upload("log")
with self.db.transaction():
# Mark the job as finished
- await job.finished(success=success, log=log)
+ await job.finished(success=success, logfile=logfile)
- # Delete the log
- await log.delete()
+ # Delete the logfile
+ await logfile.delete()