@@ -595,7 +595,7 @@ def _add_key(self, key: str, val: str):
595
595
(str (version_update ),))
596
596
self .ioctx .operate_write_op (write_op , self .omap_name )
597
597
self .version = version_update
598
- self .logger .debug (f"omap_key generated: { key } " )
598
+ self .logger .info (f"omap_key generated: { key } , OMAP version: { version_update } " )
599
599
except Exception :
600
600
self .logger .exception ("Unable to add key to OMAP, exiting!" )
601
601
raise
@@ -1047,9 +1047,11 @@ def update(self) -> bool:
1047
1047
omap_version = int (omap_state_dict [self .omap .OMAP_VERSION_KEY ])
1048
1048
local_version = self .omap .get_local_version ()
1049
1049
1050
+ self .logger .info (f"Check local version { local_version } against OMAP version "
1051
+ f"{ omap_version } " )
1050
1052
if local_version < omap_version :
1051
- self .logger .debug (f"Start update from { local_version } to "
1052
- f" { omap_version } ({ self .id_text } )." )
1053
+ self .logger .info (f"Start update from { local_version } to { omap_version } "
1054
+ f" ({ self .id_text } )." )
1053
1055
local_state_dict = self .local .get_state ()
1054
1056
local_state_keys = local_state_dict .keys ()
1055
1057
omap_state_keys = omap_state_dict .keys ()
@@ -1242,9 +1244,8 @@ def update(self) -> bool:
1242
1244
# Update local state and version
1243
1245
self .local .reset (omap_state_dict )
1244
1246
self .omap .set_local_version (omap_version )
1245
- self .logger .debug (f"Update complete ({ local_version } -> "
1246
- f"{ omap_version } ) ({ self .id_text } )." )
1247
-
1247
+ self .logger .info (f"Update complete ({ local_version } -> { omap_version } ) "
1248
+ f"({ self .id_text } )." )
1248
1249
return True
1249
1250
1250
1251
def _group_by_prefix (self , state_update , prefix_list ):
0 commit comments