@@ -111,9 +111,11 @@ def begin(self, isolation_level=0):
111111
112112 # Something is wrong, emit exception
113113 else :
114- raise QueryException ('Invalid isolation level "{}"' .format (isolation_level ))
114+ raise QueryException ('Invalid isolation level "{}"' .format (
115+ isolation_level ))
115116
116- self .cursor .execute ('SET TRANSACTION ISOLATION LEVEL {}' .format (isolation_level ))
117+ self .cursor .execute ('SET TRANSACTION ISOLATION LEVEL {}' .format (
118+ isolation_level ))
117119
118120 def commit (self ):
119121 self .connection .commit ()
@@ -228,7 +230,8 @@ def init(self, allows_streaming=False):
228230
229231 return self
230232
231- def init_from_backup (self , root_node , backup_name , has_streaming = False , hba_permit_replication = True ):
233+ def init_from_backup (self , root_node , backup_name , has_streaming = False ,
234+ hba_permit_replication = True ):
232235 """Initializes cluster from backup, made by another node"""
233236
234237 # Copy data from backup
@@ -446,7 +449,8 @@ def backup(self, name):
446449 pg_basebackup = self .get_bin_path ("pg_basebackup" )
447450 backup_path = os .path .join (self .base_dir , name )
448451 os .makedirs (backup_path )
449- params = [pg_basebackup , "-D" , backup_path , "-p {}" .format (self .port ), "-x" ]
452+ params = [pg_basebackup , "-D" , backup_path , "-p {}" .format (
453+ self .port ), "-x" ]
450454 with open (self .output_filename , "a" ) as file_out , \
451455 open (self .error_filename , "a" ) as file_err :
452456 ret = subprocess .call (
0 commit comments