Revision 6e237482 lib/jqueue.py
| b/lib/jqueue.py | ||
|---|---|---|
| 1101 | 1101 |
|
| 1102 | 1102 |
""" |
| 1103 | 1103 |
logging.debug("Waiting for changes in job %s", job_id)
|
| 1104 |
|
|
| 1105 |
job_info = None |
|
| 1106 |
log_entries = None |
|
| 1107 |
|
|
| 1104 | 1108 |
end_time = time.time() + timeout |
| 1105 | 1109 |
while True: |
| 1106 | 1110 |
delta_time = end_time - time.time() |
| ... | ... | |
| 1142 | 1146 |
|
| 1143 | 1147 |
logging.debug("Job %s changed", job_id)
|
| 1144 | 1148 |
|
| 1145 |
return (job_info, log_entries) |
|
| 1149 |
if job_info is None and log_entries is None: |
|
| 1150 |
return None |
|
| 1151 |
else: |
|
| 1152 |
return (job_info, log_entries) |
|
| 1146 | 1153 |
|
| 1147 | 1154 |
@utils.LockedMethod |
| 1148 | 1155 |
@_RequireOpenQueue |
Also available in: Unified diff