vbatts/quay
Archived
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

We need to call build_finished async.

Browse source
This commit is contained in:
Jake Moshenko 2014-12-23 16:04:10 -05:00
parent 8e16fbf59b
commit ef70432b11
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
buildman/component/buildcomponent.py
View file

@ -247,7 +247,7 @@ class BuildComponent(BaseComponent):
logger.warning('Build %s failed with message: %s', build_id, error_message) logger.warning('Build %s failed with message: %s', build_id, error_message)
# Mark that the build has finished (in an error state) # Mark that the build has finished (in an error state)
self._build_finished(BuildJobResult.ERROR) trollius.async(self._build_finished(BuildJobResult.ERROR))
def _build_complete(self, result): def _build_complete(self, result):
""" Wraps up a completed build. Handles any errors and calls self._build_finished. """ """ Wraps up a completed build. Handles any errors and calls self._build_finished. """
@ -255,7 +255,7 @@ class BuildComponent(BaseComponent):
# Retrieve the result. This will raise an ApplicationError on any error that occurred. # Retrieve the result. This will raise an ApplicationError on any error that occurred.
result.result() result.result()
self._build_status.set_phase(BUILD_PHASE.COMPLETE) self._build_status.set_phase(BUILD_PHASE.COMPLETE)
self._build_finished(BuildJobResult.COMPLETE) trollius.async(self._build_finished(BuildJobResult.COMPLETE))
except ApplicationError as aex: except ApplicationError as aex:
worker_error = WorkerError(aex.error, aex.kwargs.get('base_error')) worker_error = WorkerError(aex.error, aex.kwargs.get('base_error'))
@ -265,9 +265,9 @@ class BuildComponent(BaseComponent):
# Mark the build as completed. # Mark the build as completed.
if worker_error.is_internal_error(): if worker_error.is_internal_error():
self._build_finished(BuildJobResult.INCOMPLETE) trollius.async(self._build_finished(BuildJobResult.INCOMPLETE))
else: else:
self._build_finished(BuildJobResult.ERROR) trollius.async(self._build_finished(BuildJobResult.ERROR))
@trollius.coroutine @trollius.coroutine
def _build_finished(self, job_status): def _build_finished(self, job_status):