#NEWLINE# def job( self , name , fn , dependencies , size = 0 , on_success = None , on_failure = None ) : #NEWLINE# #INDENT# def recording_fn( ) : #NEWLINE# #INDENT# self . jobs_run . append ( name ) #NEWLINE# fn ( ) #NEWLINE# #UNINDENT# return Job ( name , recording_fn , dependencies , size , on_success , on_failure )