77from six import raise_from
88
99from .consts import \
10- DATA_DIR as _DATA_DIR , \
11- PG_CONF_FILE as _PG_CONF_FILE , \
12- BACKUP_LOG_FILE as _BACKUP_LOG_FILE , \
13- DEFAULT_XLOG_METHOD as _DEFAULT_XLOG_METHOD
10+ DATA_DIR , \
11+ PG_CONF_FILE , \
12+ BACKUP_LOG_FILE , \
13+ DEFAULT_XLOG_METHOD
1414
1515from .exceptions import BackupException
1616
1717from .utils import \
1818get_bin_path , \
19- default_username as _default_username , \
20- execute_utility as _execute_utility
19+ default_username , \
20+ execute_utility
2121
2222
2323class NodeBackup (object ):
@@ -27,13 +27,13 @@ class NodeBackup(object):
2727
2828@property
2929def log_file (self ):
30- return os .path .join (self .base_dir ,_BACKUP_LOG_FILE )
30+ return os .path .join (self .base_dir ,BACKUP_LOG_FILE )
3131
3232def __init__ (self ,
3333node ,
3434base_dir = None ,
3535username = None ,
36- xlog_method = _DEFAULT_XLOG_METHOD ):
36+ xlog_method = DEFAULT_XLOG_METHOD ):
3737"""
3838 Create a new backup.
3939
@@ -48,7 +48,7 @@ def __init__(self,
4848raise BackupException ('Node must be running' )
4949
5050# Set default arguments
51- username = username or _default_username ()
51+ username = username or default_username ()
5252base_dir = base_dir or tempfile .mkdtemp ()
5353
5454# public
@@ -59,7 +59,7 @@ def __init__(self,
5959# private
6060self ._available = True
6161
62- data_dir = os .path .join (self .base_dir ,_DATA_DIR )
62+ data_dir = os .path .join (self .base_dir ,DATA_DIR )
6363
6464# yapf: disable
6565_params = [
@@ -70,7 +70,7 @@ def __init__(self,
7070"-D" ,data_dir ,
7171"-X" ,xlog_method
7272 ]
73- _execute_utility (_params ,self .log_file )
73+ execute_utility (_params ,self .log_file )
7474
7575def __enter__ (self ):
7676return self
@@ -98,8 +98,8 @@ def _prepare_dir(self, destroy):
9898if available :
9999dest_base_dir = tempfile .mkdtemp ()
100100
101- data1 = os .path .join (self .base_dir ,_DATA_DIR )
102- data2 = os .path .join (dest_base_dir ,_DATA_DIR )
101+ data1 = os .path .join (self .base_dir ,DATA_DIR )
102+ data2 = os .path .join (dest_base_dir ,DATA_DIR )
103103
104104try :
105105# Copy backup to new data dir
@@ -140,8 +140,8 @@ def spawn_primary(self, name=None, destroy=True, use_logging=False):
140140# New nodes should always remove dir tree
141141node ._should_rm_dirs = True
142142
143- node .append_conf (_PG_CONF_FILE ,"\n " )
144- node .append_conf (_PG_CONF_FILE ,"port = {}" .format (node .port ))
143+ node .append_conf (PG_CONF_FILE ,"\n " )
144+ node .append_conf (PG_CONF_FILE ,"port = {}" .format (node .port ))
145145
146146return node
147147