1010from six import raise_from ,iteritems
1111from tempfile import mkstemp ,mkdtemp
1212
13- from .enums import NodeStatus ,ProcessType
13+ from .enums import \
14+ NodeStatus , \
15+ ProcessType , \
16+ DumpFormat
1417
1518from .cache import cached_initdb
1619
3235RECOVERY_CONF_FILE , \
3336PG_LOG_FILE , \
3437UTILS_LOG_FILE , \
35- DEFAULT_DUMP_FORMAT , \
36- DUMP_DIRECTORY , \
3738PG_PID_FILE
3839
3940from .consts import \
@@ -805,23 +806,27 @@ def safe_psql(self, query=None, **kwargs):
805806
806807return out
807808
808- def dump (self ,filename = None ,dbname = None ,username = None ,format = DEFAULT_DUMP_FORMAT ):
809+ def dump (self ,
810+ filename = None ,
811+ dbname = None ,
812+ username = None ,
813+ format = DumpFormat .Plain ):
809814"""
810815 Dump database into a file using pg_dump.
811816 NOTE: the file is not removed automatically.
812817
813818 Args:
819+ filename: database dump taken by pg_dump.
814820 dbname: database name to connect to.
815821 username: database user name.
816- filename: output file.
817- format: format argument plain/custom/directory/tar
822+ format: format argument plain/custom/directory/tar.
818823
819824 Returns:
820825 Path to a file containing dump.
821826 """
822827
823828def tmpfile ():
824- if format == DUMP_DIRECTORY :
829+ if format == DumpFormat . Directory :
825830fname = mkdtemp (prefix = TMP_DUMP )
826831else :
827832fd ,fname = mkstemp (prefix = TMP_DUMP )
@@ -852,7 +857,7 @@ def restore(self, filename, dbname=None, username=None):
852857 Restore database from pg_dump's file.
853858
854859 Args:
855- filename:input file .
860+ filename:database dump taken by pg_dump in custom/directory/tar formats .
856861 dbname: database name to connect to.
857862 username: database user name.
858863 """
@@ -862,17 +867,13 @@ def restore(self, filename, dbname=None, username=None):
862867username = username or default_username ()
863868
864869_params = [
865- get_bin_path ("pg_restore" ),
866- "-p" ,str (self .port ),
867- "-h" ,self .host ,
868- "-U" ,username ,
869- "-d" ,dbname ,
870+ get_bin_path ("pg_restore" ),"-p" ,
871+ str (self .port ),"-h" ,self .host ,"-U" ,username ,"-d" ,dbname ,
870872filename
871873 ]
872874
873875execute_utility (_params ,self .utils_log_name )
874876
875-
876877@method_decorator (positional_args_hack (['dbname' ,'query' ]))
877878def poll_query_until (self ,
878879query ,