@@ -385,7 +385,7 @@ async def test_backup_simple(self):
385385 with backup .spawn_primary ('slave' ) as slave :
386386 slave .start ()
387387 res = await slave .fetch ('postgres' ,
388- 'select * from test order by i asc' )
388+ 'select * from test order by i asc' )
389389 self .assertListEqual (res , [(1 , ), (2 , ), (3 , ), (4 , )])
390390
391391 async def test_dump (self ):
@@ -406,7 +406,7 @@ async def test_dump(self):
406406 node2 .init ().start ().restore ('postgres' , dump )
407407
408408 res = await node2 .fetch ('postgres' ,
409- 'select * from test order by val asc' )
409+ 'select * from test order by val asc' )
410410 self .assertListEqual (res , [(1 , ), (2 , )])
411411
412412 # finally, remove dump
@@ -475,17 +475,17 @@ async def test_poll_query_until(self):
475475 # check 0 columns
476476 with self .assertRaises (QueryException ):
477477 await node .poll_query_until ('postgres' ,
478- 'select from pg_class limit 1' )
478+ 'select from pg_class limit 1' )
479479 # check None
480480 with self .assertRaises (QueryException ):
481481 await node .poll_query_until ('postgres' , 'create table abc (val int)' )
482482
483483 # check timeout
484484 with self .assertRaises (TimeoutException ):
485485 await node .poll_query_until (dbname = 'postgres' ,
486- query = 'select 1 > 2' ,
487- max_attempts = 5 ,
488- sleep_time = 0.2 )
486+ query = 'select 1 > 2' ,
487+ max_attempts = 5 ,
488+ sleep_time = 0.2 )
489489
490490 async def test_replicate (self ):
491491 with get_new_node ('node' ) as node :
0 commit comments