#NEWLINE# def __init__( self , config = None , rradir = None , rrdcache = None , monitor_port = None , default_timeout = 15 , **kwargs ) : #NEWLINE# #INDENT# self . _registered = set ( ) #NEWLINE# self . _group_index = defaultdict ( set ) #NEWLINE# self . _startup = True #NEWLINE# self . _shutdown = None #NEWLINE# self . _latency = deque ( [ 0 ] , 60 ) #NEWLINE# self . _latency_call = None #NEWLINE# self . _task_stats = { #NEWLINE# #INDENT# 'count' : 0 , #NEWLINE# 'Group' : { #NEWLINE# #INDENT# 'count' : 0 , #NEWLINE# #UNINDENT# } , #NEWLINE# 'Test' : { #NEWLINE# #INDENT# 'count' : 0 , #NEWLINE# #UNINDENT# } , #NEWLINE# 'Query' : { #NEWLINE# #INDENT# 'count' : 0 , #NEWLINE# #UNINDENT# } , #NEWLINE# #UNINDENT# } #NEWLINE# self . default_timeout = default_timeout #NEWLINE# if monitor_port : #NEWLINE# #INDENT# self . _monitor_port = monitor_port #NEWLINE# self . monitor = monitor_api . MonitorSite ( ) #NEWLINE# page = SchedulerPage ( self ) #NEWLINE# self . monitor . includeChild ( 'scheduler' , page ) #NEWLINE# #UNINDENT# if rradir : #NEWLINE# #INDENT# self . trend = trend . TrendMaster ( rradir , rrdcache ) #NEWLINE# #UNINDENT# self . query = query . QueryManager ( self ) #NEWLINE# self . build_tests ( config , ** kwargs )