Skip to content
Snippets Groups Projects
Commit 4f44c644 authored by André Anjos's avatar André Anjos :speech_balloon:
Browse files

[backend] More error messages

parent 0611531f
No related branches found
No related tags found
No related merge requests found
Pipeline #
...@@ -440,9 +440,9 @@ class Worker(models.Model): ...@@ -440,9 +440,9 @@ class Worker(models.Model):
else: # process went away without any apparent reason else: # process went away without any apparent reason
with transaction.atomic(): with transaction.atomic():
message = "Split %d/%d running at worker `%s' for " \ message = "Split %d/%d running at worker `%s' for " \
"block `%s' of experiment `%s' finished without any " \ "block `%s' of experiment `%s' finished before " \
"apparent reason. Checking-out job split at " \ "even starting. Force-cancelling job split at " \
"database by force..." % (j.split_index+1, "database..." % (j.split_index+1,
j.job.block.required_slots, j.job.block.required_slots,
self, self,
j.job.block.name, j.job.block.name,
...@@ -1485,6 +1485,9 @@ class JobSplit(models.Model): ...@@ -1485,6 +1485,9 @@ class JobSplit(models.Model):
self, os.getpid(), traceback.format_exc()) self, os.getpid(), traceback.format_exc())
self.signal_io_error() self.signal_io_error()
if self.cache_errors > settings.MAXIMUM_IO_ERRORS: if self.cache_errors > settings.MAXIMUM_IO_ERRORS:
logger.info("Split `%s' reached the maximum number of IO " \
"errors (%d > %d). Force failing this split." % \
(self, self.cache_errors, settings.MAXIMUM_IO_ERRORS))
self.try_end(Result(status=1, self.try_end(Result(status=1,
usrerr=settings.DEFAULT_USER_ERROR, usrerr=settings.DEFAULT_USER_ERROR,
syserr=traceback.format_exc(),)) syserr=traceback.format_exc(),))
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment