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