#NEWLINE# def _check_queue( queue , kwargs ) : #NEWLINE# #INDENT# '\n    Utility function to queue the state run if requested\n    and to check for conflicts in currently running states\n    ' #NEWLINE# if queue : #NEWLINE# #INDENT# _wait ( kwargs . get ( '__pub_jid' ) ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# conflict = running ( ) #NEWLINE# if conflict : #NEWLINE# #INDENT# __context__ [ 'retcode' ] = 1 #NEWLINE# return queue