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