#NEWLINE# def _make_engine( self , flow , flow_detail = None , executor = None , store = None , **kwargs ) : #NEWLINE# #INDENT# if ( executor is None ) : #NEWLINE# #INDENT# executor = futurist . GreenThreadPoolExecutor ( ) #NEWLINE# self . addCleanup ( executor . shutdown ) #NEWLINE# #UNINDENT# return taskflow . engines . load ( flow , flow_detail = flow_detail , backend = self . backend , engine = 'parallel' , executor = executor , store = store , ** kwargs )