Skip to content
Snippets Groups Projects
Commit e0f2bf1e authored by Michele Tartara's avatar Michele Tartara
Browse files

Add job_id and index to the reason trail


The reason trail will contain an item indicating the job_id and the
index number of the current opcode inside the job queue.

Signed-off-by: default avatarMichele Tartara <mtartara@google.com>
Reviewed-by: default avatarHelga Velroyen <helgav@google.com>
parent 276e51bd
No related branches found
No related tags found
No related merge requests found
......@@ -222,6 +222,22 @@ class _QueuedJob(object):
"received_timestamp", "start_timestamp", "end_timestamp",
"__weakref__", "processor_lock", "writable", "archived"]
def _AddReasons(self):
"""Extend the reason trail
Add the reason for all the opcodes of this job to be executed.
"""
count = 0
for queued_op in self.ops:
op = queued_op.input
reason_src = opcodes.NameToReasonSrc(op.__class__.__name__)
reason_text = "job=%d;index=%d" % (self.id, count)
reason = getattr(op, "reason", [])
reason.append((reason_src, reason_text, utils.EpochNano()))
op.reason = reason
count = count + 1
def __init__(self, queue, job_id, ops, writable):
"""Constructor for the _QueuedJob.
......@@ -242,6 +258,7 @@ class _QueuedJob(object):
self.queue = queue
self.id = int(job_id)
self.ops = [_QueuedOpCode(op) for op in ops]
self._AddReasons()
self.log_serial = 0
self.received_timestamp = TimeStampNow()
self.start_timestamp = None
......
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