#NEWLINE# def test_query_apply_with_extra_call_to_lua( self ) : #NEWLINE# #INDENT# '\n        Invoke query_apply() with extra call to lua\n        ' #NEWLINE# query_id = self . client . query_apply ( 'test' , 'demo' , p . between ( 'age' , 1 , 5 ) , 'bin_lua' , 'mytransform' , [ 'age' , 2 , 3 ] ) #NEWLINE# time . sleep ( 0.1 ) #NEWLINE# while True : #NEWLINE# #INDENT# response = self . client . job_info ( query_id , aerospike . JOB_QUERY ) #NEWLINE# if ( response [ 'status' ] != aerospike . JOB_STATUS_INPROGRESS ) : #NEWLINE# #INDENT# break #NEWLINE# #UNINDENT# time . sleep ( 0.1 ) #NEWLINE# #UNINDENT# for i in range ( 1 , 5 ) : #NEWLINE# #INDENT# key = ( 'test' , 'demo' , i ) #NEWLINE# ( key , _ , bins ) = self . client . get ( key ) #NEWLINE# if ( bins [ 'age' ] != ( i + 2 ) ) : #NEWLINE# #INDENT# assert ( True is False ) #NEWLINE# #UNINDENT# #UNINDENT# assert ( True is True )