@@ -16,15 +16,13 @@ def setup_method(self):
1616 self .r .table (self .table_name ).insert (self .documents ).run (self .conn )
1717
1818 def test_set_write_hook (self ):
19- self .r .table (self .table_name ).set_write_hook (lambda context , old_val , new_val :
19+ response = self .r .table (self .table_name ).set_write_hook (lambda context , old_val , new_val :
2020 new_val .merge ({
2121 'modified_at' : context ['timestamp' ]
2222 })
2323 ).run (self .conn )
2424
25- hook = self .r .table (self .table_name ).get_write_hook ().run (self .conn )
26-
27- assert hook .keys () == ['function' , 'query' ]
25+ assert response == {'created' : 1 }
2826
2927 def test_write_hook_add_extra_data (self ):
3028 self .r .table (self .table_name ).set_write_hook (lambda context , old_val , new_val :
@@ -39,4 +37,15 @@ def test_write_hook_add_extra_data(self):
3937
4038 document = self .r .table (self .table_name ).get (2 ).run (self .conn )
4139
42- assert document .get ('modified_at' ) != None
40+ assert document .get ('modified_at' ) != None
41+
42+ def test_get_write_hook (self ):
43+ self .r .table (self .table_name ).set_write_hook (lambda context , old_val , new_val :
44+ new_val .merge ({
45+ 'modified_at' : context ['timestamp' ]
46+ })
47+ ).run (self .conn )
48+
49+ hook = self .r .table (self .table_name ).get_write_hook ().run (self .conn )
50+
51+ assert list (hook .keys ()) == ['function' , 'query' ]
0 commit comments