#NEWLINE# def command( self , * args , **options ) : #NEWLINE# #INDENT# config_file = args [ 0 ] #NEWLINE# wrapper = WorkflowWrapper ( config_file , NaiveWorkflow ) #NEWLINE# wrapper . run ( ) #NEWLINE# if ( ( 'shell' in options ) and options [ 'shell' ] ) : #NEWLINE# #INDENT# ns = { #NEWLINE# #INDENT# 'flow' : wrapper . workflow , #NEWLINE# 'tasks' : wrapper . workflow . tasks , #NEWLINE# #UNINDENT# } #NEWLINE# IPython . embed ( user_ns = ns , banner2 = 'This shell session has been started in the namespace for your project.  You can access the following variables:flow - The workflow that just ran.tasks - the completed tasks that the workflow ran.' )