#NEWLINE# def test_node_volumes_modification_adds_pending_changes( self ) : #NEWLINE# #INDENT# cluster = self . env . create_cluster ( api = True ) #NEWLINE# self . env . create_node ( api = True , cluster_id = cluster [ 'id' ] ) #NEWLINE# node_db = self . env . nodes [ 0 ] #NEWLINE# node_disks_changes = self . db . query ( ClusterChanges ) . filter_by ( name = 'disks' , node_id = node_db . id ) . all ( ) #NEWLINE# self . assertEqual ( len ( node_disks_changes ) , 1 ) #NEWLINE# resp = self . app . get ( reverse ( 'ClusterHandler' , kwargs = { #NEWLINE# #INDENT# 'obj_id' : cluster [ 'id' ] , #NEWLINE# #UNINDENT# } ) , headers = self . default_headers ) #NEWLINE# self . assertIn ( { #NEWLINE# #INDENT# 'name' : 'disks' , #NEWLINE# 'node_id' : node_db . id , #NEWLINE# #UNINDENT# } , resp . json_body [ 'changes' ] )