self.op_id += 1
local_op_id = self.local_lock_id + ':' + str(self.op_id)
try:
- found = True
until = time.time() + self.object_sync_timeout
client.sync_object_intra_region(self.dest_conn, bucket, obj,
self.src.zone.name,
self.daemon_id,
local_op_id)
+ found = True
except client.NotFound:
found = False
log.debug('"%s/%s" not found on master, deleting from secondary',
except SyncFailed:
raise
except Exception as e:
- log.debug('exception during sync: %s', e)
+ log.exception('encountered an exception during sync')
if found:
self.wait_for_object(bucket, obj, until, local_op_id)
# TODO: clean up old op states