@@ -518,7 +518,7 @@ def _add_key(self, key: str, val: str):
518
518
(str (version_update ),))
519
519
self .ioctx .operate_write_op (write_op , self .omap_name )
520
520
self .version = version_update
521
- self .logger .debug (f"omap_key generated: { key } " )
521
+ self .logger .info (f"omap_key generated: { key } , OMAP version: { version_update } " )
522
522
except Exception :
523
523
self .logger .exception (f"Unable to add key to OMAP, exiting!" )
524
524
raise
@@ -912,8 +912,9 @@ def update(self) -> bool:
912
912
omap_version = int (omap_state_dict [self .omap .OMAP_VERSION_KEY ])
913
913
local_version = self .omap .get_local_version ()
914
914
915
+ self .logger .info (f"Check local version { local_version } against OMAP version { omap_version } " )
915
916
if local_version < omap_version :
916
- self .logger .debug (f"Start update from { local_version } to { omap_version } ({ self .id_text } )." )
917
+ self .logger .info (f"Start update from { local_version } to { omap_version } ({ self .id_text } )." )
917
918
local_state_dict = self .local .get_state ()
918
919
local_state_keys = local_state_dict .keys ()
919
920
omap_state_keys = omap_state_dict .keys ()
@@ -1055,7 +1056,7 @@ def update(self) -> bool:
1055
1056
# Update local state and version
1056
1057
self .local .reset (omap_state_dict )
1057
1058
self .omap .set_local_version (omap_version )
1058
- self .logger .debug (f"Update complete ({ local_version } -> { omap_version } ) ({ self .id_text } )." )
1059
+ self .logger .info (f"Update complete ({ local_version } -> { omap_version } ) ({ self .id_text } )." )
1059
1060
1060
1061
return True
1061
1062
0 commit comments