Revision 403f5172 lib/masterd/instance.py
| b/lib/masterd/instance.py | ||
|---|---|---|
| 793 | 793 |
logging.exception("%s failed", diskie.MODE_TEXT)
|
| 794 | 794 |
diskie.Finalize(error=str(err)) |
| 795 | 795 |
|
| 796 |
if not compat.any([diskie.active for diskie in self._queue]):
|
|
| 796 |
if not compat.any(diskie.active for diskie in self._queue):
|
|
| 797 | 797 |
break |
| 798 | 798 |
|
| 799 | 799 |
# Wait a bit |
| ... | ... | |
| 1060 | 1060 |
ieloop.FinalizeAll() |
| 1061 | 1061 |
|
| 1062 | 1062 |
assert len(all_dtp) == len(all_transfers) |
| 1063 |
assert compat.all([(dtp.src_export is None or
|
|
| 1063 |
assert compat.all((dtp.src_export is None or |
|
| 1064 | 1064 |
dtp.src_export.success is not None) and |
| 1065 | 1065 |
(dtp.dest_import is None or |
| 1066 | 1066 |
dtp.dest_import.success is not None) |
| 1067 |
for dtp in all_dtp]), \
|
|
| 1067 |
for dtp in all_dtp), \ |
|
| 1068 | 1068 |
"Not all imports/exports are finalized" |
| 1069 | 1069 |
|
| 1070 | 1070 |
return [bool(dtp.success) for dtp in all_dtp] |
Also available in: Unified diff