sync_latest_snapshot = False
sync_from_snapshot = None
if lookup_info:
- sync_latest_snapshot = lookup_info['sync_latest_snapshot']
- sync_from_snapshot = lookup_info['sync_from_snapshot']
+ sync_latest_snapshot = lookup_info['sync_latest_snapshot'] if 'sync_latest_snapshot' in lookup_info else False
+ sync_from_snapshot = lookup_info['sync_from_snapshot'] if 'sync_from_snapshot' in lookup_info else None
return json.dumps({'dir_path': dir_path,
'mode': 'acquire',
'sync_latest_snapshot': sync_latest_snapshot,
continue
elif action_type == ActionType.MAP_UPDATE:
# take care to not overwrite purge status
- update_map[dir_path] = {'version': 1,
- 'instance_id': lookup_info['instance_id'],
- 'last_shuffled': lookup_info['mapped_time'],
- 'sync_latest_snapshot': lookup_info['sync_latest_snapshot'],
- 'sync_from_snapshot': lookup_info['sync_from_snapshot']
+ update_map[dir_path] = {
+ 'version': 1,
+ 'instance_id': lookup_info['instance_id'],
+ 'last_shuffled': lookup_info['mapped_time'],
+ 'sync_latest_snapshot': lookup_info['sync_latest_snapshot'] if 'sync_latest_snapshot' in lookup_info else False,
+ 'sync_from_snapshot': lookup_info['sync_from_snapshot'] if 'sync_from_snapshot' in lookup_info else None
}
if lookup_info['purging']:
update_map[dir_path]['purging'] = 1