Revision b9b5abcb lib/jqueue.py

b/lib/jqueue.py
77 77
  @ivar status: the current status
78 78
  @ivar result: the result of the LU execution
79 79
  @ivar start_timestamp: timestamp for the start of the execution
80
  @ivar exec_timestamp: timestamp for the actual LU Exec() function invocation
80 81
  @ivar stop_timestamp: timestamp for the end of the execution
81 82

  
82 83
  """
83 84
  __slots__ = ["input", "status", "result", "log",
84
               "start_timestamp", "end_timestamp",
85
               "start_timestamp", "exec_timestamp", "end_timestamp",
85 86
               "__weakref__"]
86 87

  
87 88
  def __init__(self, op):
......
96 97
    self.result = None
97 98
    self.log = []
98 99
    self.start_timestamp = None
100
    self.exec_timestamp = None
99 101
    self.end_timestamp = None
100 102

  
101 103
  @classmethod
......
114 116
    obj.result = state["result"]
115 117
    obj.log = state["log"]
116 118
    obj.start_timestamp = state.get("start_timestamp", None)
119
    obj.exec_timestamp = state.get("exec_timestamp", None)
117 120
    obj.end_timestamp = state.get("end_timestamp", None)
118 121
    return obj
119 122

  
......
130 133
      "result": self.result,
131 134
      "log": self.log,
132 135
      "start_timestamp": self.start_timestamp,
136
      "exec_timestamp": self.exec_timestamp,
133 137
      "end_timestamp": self.end_timestamp,
134 138
      }
135 139

  
......
385 389
        raise CancelJob()
386 390

  
387 391
      self._op.status = constants.OP_STATUS_RUNNING
392
      self._op.exec_timestamp = TimeStampNow()
388 393
    finally:
389 394
      self._queue.release()
390 395

  
......
1383 1388
        row.append([op.log for op in job.ops])
1384 1389
      elif fname == "opstart":
1385 1390
        row.append([op.start_timestamp for op in job.ops])
1391
      elif fname == "opexec":
1392
        row.append([op.exec_timestamp for op in job.ops])
1386 1393
      elif fname == "opend":
1387 1394
        row.append([op.end_timestamp for op in job.ops])
1388 1395
      elif fname == "received_ts":

Also available in: Unified diff