Commit b3855790 authored by Guido Trotter's avatar Guido Trotter
Browse files

Update the job file on feedback



This is needed to convert waitforjobchanges to use inotify and the
on-disk version and decouple it from the job queue lock. No replication
to remote nodes is done, to keep the operation fast.
Signed-off-by: default avatarGuido Trotter <ultrotter@google.com>
Reviewed-by: default avatarIustin Pop <iustin@google.com>
parent 9f7b4967
...@@ -457,6 +457,7 @@ class _OpExecCallbacks(mcpu.OpExecCbBase): ...@@ -457,6 +457,7 @@ class _OpExecCallbacks(mcpu.OpExecCbBase):
try: try:
self._job.log_serial += 1 self._job.log_serial += 1
self._op.log.append((self._job.log_serial, timestamp, log_type, log_msg)) self._op.log.append((self._job.log_serial, timestamp, log_type, log_msg))
self._queue.UpdateJobUnlocked(self._job, replicate=False)
self._job.change.notifyAll() self._job.change.notifyAll()
finally: finally:
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment