#NEWLINE# def run( self ) : #NEWLINE# #INDENT# setproctitle . setproctitle ( ( 'smokerd plugin %s' % self . plugin_name ) ) #NEWLINE# self . drop_privileged ( ) #NEWLINE# with semaphore : #NEWLINE# #INDENT# if ( self . params [ 'MaintenanceLock' ] and os . path . exists ( self . params [ 'MaintenanceLock' ] ) ) : #NEWLINE# #INDENT# result = Result ( ) #NEWLINE# result . set_forced ( result . forced ) #NEWLINE# result . set_status ( 'WARN' ) #NEWLINE# result . add_warn ( 'Skipped because of maintenance in progress' ) #NEWLINE# self . result = result . get_result ( ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# self . run_plugin ( self . forced ) #NEWLINE# #UNINDENT# #UNINDENT# self . queue . put ( self . result )