Merge pull request #146 from jzelinskie/timeout
help with the timeouts and all
This commit is contained in:
commit
99dff912af
1 changed files with 6 additions and 1 deletions
|
@ -195,6 +195,9 @@ class BuildComponent(BaseComponent):
|
||||||
|
|
||||||
def _on_log_message(self, phase, json_data):
|
def _on_log_message(self, phase, json_data):
|
||||||
""" Tails log messages and updates the build status. """
|
""" Tails log messages and updates the build status. """
|
||||||
|
# Update the heartbeat.
|
||||||
|
self._last_heartbeat = datetime.datetime.utcnow()
|
||||||
|
|
||||||
# Parse any of the JSON data logged.
|
# Parse any of the JSON data logged.
|
||||||
docker_data = {}
|
docker_data = {}
|
||||||
if json_data:
|
if json_data:
|
||||||
|
@ -416,7 +419,9 @@ class BuildComponent(BaseComponent):
|
||||||
self._build_status.set_error('Build worker timed out', internal_error=True,
|
self._build_status.set_error('Build worker timed out', internal_error=True,
|
||||||
requeued=self._current_job.has_retries_remaining())
|
requeued=self._current_job.has_retries_remaining())
|
||||||
|
|
||||||
self.parent_manager.job_completed(self._current_job, BuildJobResult.INCOMPLETE, self)
|
yield trollius.From(self.parent_manager.job_completed(self._current_job,
|
||||||
|
BuildJobResult.INCOMPLETE,
|
||||||
|
self))
|
||||||
self._build_status = None
|
self._build_status = None
|
||||||
self._current_job = None
|
self._current_job = None
|
||||||
|
|
||||||
|
|
Reference in a new issue