Revision aad81f98 scripts/gnt-job
b/scripts/gnt-job | ||
---|---|---|
67 | 67 |
"opstatus": "OpCode_status", |
68 | 68 |
"oplog": "OpCode_log", |
69 | 69 |
"summary": "Summary", |
70 |
"opstart": "OpCode_start", |
|
71 |
"opend": "OpCode_end", |
|
72 |
"start_ts": "Start", |
|
73 |
"end_ts": "End", |
|
74 |
"received_ts": "Received", |
|
70 | 75 |
} |
71 | 76 |
else: |
72 | 77 |
headers = None |
... | ... | |
86 | 91 |
raise errors.ProgrammerError("Unknown job status code '%s'" % val) |
87 | 92 |
elif field == "summary": |
88 | 93 |
val = ",".join(val) |
94 |
elif field in ("start_ts", "end_ts", "received_ts"): |
|
95 |
val = FormatTimestamp(val) |
|
96 |
elif field in ("opstart", "opend"): |
|
97 |
val = [FormatTimestamp(entry) for entry in val] |
|
89 | 98 |
|
90 | 99 |
row[idx] = str(val) |
91 | 100 |
|
... | ... | |
131 | 140 |
else: |
132 | 141 |
return str(value) |
133 | 142 |
|
134 |
selected_fields = ["id", "status", "ops", "opresult", "opstatus", "oplog"] |
|
143 |
selected_fields = [ |
|
144 |
"id", "status", "ops", "opresult", "opstatus", "oplog", |
|
145 |
"opstart", "opend", "received_ts", "start_ts", "end_ts", |
|
146 |
] |
|
135 | 147 |
|
136 | 148 |
result = GetClient().QueryJobs(args, selected_fields) |
137 | 149 |
|
138 | 150 |
first = True |
139 | 151 |
|
140 |
for job_id, status, ops, opresult, opstatus, oplog in result:
|
|
152 |
for entry, arg_job in zip(result, args):
|
|
141 | 153 |
if not first: |
142 | 154 |
format(0, "") |
143 | 155 |
else: |
144 | 156 |
first = False |
157 |
|
|
158 |
if entry is None: |
|
159 |
format(0, "Job ID %s not found" % arg_job) |
|
160 |
continue |
|
161 |
|
|
162 |
(job_id, status, ops, opresult, opstatus, oplog, |
|
163 |
opstart, opend, recv_ts, start_ts, end_ts) = entry |
|
145 | 164 |
format(0, "Job ID: %s" % job_id) |
146 | 165 |
if status in _USER_JOB_STATUS: |
147 | 166 |
status = _USER_JOB_STATUS[status] |
... | ... | |
149 | 168 |
raise errors.ProgrammerError("Unknown job status code '%s'" % val) |
150 | 169 |
|
151 | 170 |
format(1, "Status: %s" % status) |
171 |
|
|
172 |
if recv_ts is not None: |
|
173 |
format(1, "Received: %s" % FormatTimestamp(recv_ts)) |
|
174 |
else: |
|
175 |
format(1, "Missing received timestamp (%s)" % str(recv_ts)) |
|
176 |
|
|
177 |
if start_ts is not None: |
|
178 |
if recv_ts is not None: |
|
179 |
d1 = start_ts[0] - recv_ts[0] + (start_ts[1] - recv_ts[1]) / 1000000.0 |
|
180 |
delta = " (delta %.6fs)" % d1 |
|
181 |
else: |
|
182 |
delta = "" |
|
183 |
format(1, "Processing start: %s%s" % (FormatTimestamp(start_ts), delta)) |
|
184 |
else: |
|
185 |
format(1, "Processing start: unknown (%s)" % str(start_ts)) |
|
186 |
|
|
187 |
if end_ts is not None: |
|
188 |
if start_ts is not None: |
|
189 |
d2 = end_ts[0] - start_ts[0] + (end_ts[1] - start_ts[1]) / 1000000.0 |
|
190 |
delta = " (delta %.6fs)" % d2 |
|
191 |
else: |
|
192 |
delta = "" |
|
193 |
format(1, "Processing end: %s%s" % (FormatTimestamp(end_ts), delta)) |
|
194 |
else: |
|
195 |
format(1, "Processing end: unknown (%s)" % str(end_ts)) |
|
196 |
|
|
197 |
if end_ts is not None and recv_ts is not None: |
|
198 |
d3 = end_ts[0] - recv_ts[0] + (end_ts[1] - recv_ts[1]) / 1000000.0 |
|
199 |
format(1, "Total processing time: %.6f seconds" % d3) |
|
200 |
else: |
|
201 |
format(1, "Total processing time: N/A") |
|
152 | 202 |
format(1, "Opcodes:") |
153 |
for opcode, result, status, log in zip(ops, opresult, opstatus, oplog): |
|
203 |
for (opcode, result, status, log, s_ts, e_ts) in \ |
|
204 |
zip(ops, opresult, opstatus, oplog, opstart, opend): |
|
154 | 205 |
format(2, "%s" % opcode["OP_ID"]) |
155 | 206 |
format(3, "Status: %s" % status) |
207 |
if isinstance(s_ts, (tuple, list)): |
|
208 |
format(3, "Processing start: %s" % FormatTimestamp(s_ts)) |
|
209 |
else: |
|
210 |
format(3, "No processing start time") |
|
211 |
if isinstance(e_ts, (tuple, list)): |
|
212 |
format(3, "Processing end: %s" % FormatTimestamp(e_ts)) |
|
213 |
else: |
|
214 |
format(3, "No processing end time") |
|
156 | 215 |
format(3, "Input fields:") |
157 | 216 |
for key, val in opcode.iteritems(): |
158 | 217 |
if key == "OP_ID": |
Also available in: Unified diff