File tree Expand file tree Collapse file tree 2 files changed +6
-4
lines changed Expand file tree Collapse file tree 2 files changed +6
-4
lines changed Original file line number Diff line number Diff line change 36
36
'MetaError' : 'Metadata could not be retrieved. Check log file for more details, quitting' ,
37
37
'MetaSuccess' : 'Successfully retrieved MetaData' ,
38
38
'RequestMetaUpdate' : 'MetaData update requested' ,
39
+ 'ElapsedTimeSinceLastUpdate' : 'Elapsed time:{} since last MetaData update' ,
39
40
'QueryError' : 'Query request could not be proceed. Reason: {}' ,
40
41
'SearchErr' : 'Search for {} did cause exception: {}' ,
41
42
'LookupErr' : 'Lookup for metric {} did not return any results' ,
Original file line number Diff line number Diff line change @@ -37,7 +37,7 @@ class TopoRefreshManager(object, metaclass=Singleton):
37
37
thread = None
38
38
refresh_delay_secs = 30
39
39
40
- def __init__ (self , call_func_on_change , * args , ** kwargs ):
40
+ def __init__ (self , call_func_on_change = None , * args , ** kwargs ):
41
41
self ._cached_stamp = {}
42
42
self .logger = getBridgeLogger ()
43
43
self .update_required = False
@@ -81,11 +81,12 @@ def monitor(self):
81
81
if self .update_required :
82
82
md = MetadataHandler ()
83
83
elapsed_time = time .time () - md .getUpdateTime
84
- # self.logger.trace(f"Elapsed time{ elapsed_time}" )
84
+ self .logger .trace (MSG [ 'ElapsedTimeSinceLastUpdate' ]. format ( elapsed_time ) )
85
85
if elapsed_time > 300 or self .new_keys > 100 :
86
86
self .logger .info (MSG ['RequestMetaUpdate' ])
87
- self .call_func_on_change (* self .args , ** self .kwargs )
88
- self .clear_local_cache ()
87
+ if self .call_func_on_change is not None :
88
+ self .call_func_on_change (* self .args , ** self .kwargs )
89
+ self .clear_local_cache ()
89
90
except KeyboardInterrupt :
90
91
self .logger .details (MSG ['StopMonitoringTopoChanges' ])
91
92
break
You can’t perform that action at this time.
0 commit comments