#NEWLINE# @ pytest . mark . parametrize ( 'data' , [ 1 , 3 ] ) #NEWLINE# def test_pipeline_overwrites_tool( data ) : #NEWLINE# #INDENT# @ jip . tool ( ) #NEWLINE# class MyTool ( ) : #NEWLINE# #INDENT# def setup( self ) : #NEWLINE# #INDENT# self . profile . threads = 2 #NEWLINE# #UNINDENT# def get_command( self ) : #NEWLINE# #INDENT# return 'echo' #NEWLINE# #UNINDENT# #UNINDENT# @ jip . pipeline ( ) #NEWLINE# class MyPipeline ( ) : #NEWLINE# #INDENT# def pipeline( self ) : #NEWLINE# #INDENT# p = jip . Pipeline ( ) #NEWLINE# p . job ( threads = data ) . run ( 'MyTool' ) #NEWLINE# return p #NEWLINE# #UNINDENT# #UNINDENT# p = jip . Pipeline ( ) #NEWLINE# p . run ( 'MyPipeline' ) #NEWLINE# p . expand ( ) #NEWLINE# jobs = jip . create_jobs ( data ) #NEWLINE# assert ( jobs [ 0 ] . threads == data )