#NEWLINE# def test_process_task_de_duplication( self ) : #NEWLINE# #INDENT# task = { #NEWLINE# #INDENT# 'id' : 'test' , #NEWLINE# 'type' : 'puppet' , #NEWLINE# 'parameters' : { #NEWLINE# #INDENT# #NEWLINE# #UNINDENT# } , #NEWLINE# 'version' : '2.0.0' , #NEWLINE# #UNINDENT# } #NEWLINE# node_id = self . env . nodes [ ( - 1 ) ] . uid #NEWLINE# self . serializer . process_task ( task , task_based_deployment . NullResolver ( [ task ] ) ) #NEWLINE# self . serializer . process_task ( task , task_based_deployment . NullResolver ( [ node_id ] ) ) #NEWLINE# self . assertItemsEqual ( [ node_id ] , self . serializer . tasks_connections ) #NEWLINE# self . assertItemsEqual ( [ 'test' ] , self . serializer . tasks_connections [ node_id ] ) #NEWLINE# self . assertEqual ( 'test' , self . serializer . tasks_connections [ node_id ] [ 'test' ] [ 'id' ] ) #NEWLINE# self . assertEqual ( 'puppet' , self . serializer . tasks_connections [ node_id ] [ 'test' ] [ 'type' ] ) #NEWLINE# self . assertNotIn ( 'skipped' , self . serializer . tasks_connections [ node_id ] [ 'test' ] [ 'type' ] )