Commit8a25cb3

authored

Add pgbench_with_wait function (#122)

1 parent0cf30a7 commit8a25cb3Copy full SHA for 8a25cb3

File tree

+26

-1

lines changed

+26

-1

lines changed

Lines changed: 26 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -1371,7 +1371,7 @@ def pgbench(self,`
`1371`	`1371`	`username=None,`
`1372`	`1372`	`stdout=None,`
`1373`	`1373`	`stderr=None,`
`1374`		`-options=[]):`
	`1374`	`+options=None):`
`1375`	`1375`	`"""`
`1376`	`1376`	`Spawn a pgbench process.`
`1377`	`1377`
`@@ -1385,6 +1385,8 @@ def pgbench(self,`
`1385`	`1385`	`Returns:`
`1386`	`1386`	`Process created by subprocess.Popen.`
`1387`	`1387`	`"""`
	`1388`	`+ifoptionsisNone:`
	`1389`	`+options= []`
`1388`	`1390`
`1389`	`1391`	`# Set default arguments`
`1390`	`1392`	`dbname=dbnameordefault_dbname()`
`@@ -1404,6 +1406,29 @@ def pgbench(self,`
`1404`	`1406`
`1405`	`1407`	`returnproc`
`1406`	`1408`
	`1409`	`+defpgbench_with_wait(self,`
	`1410`	`+dbname=None,`
	`1411`	`+username=None,`
	`1412`	`+stdout=None,`
	`1413`	`+stderr=None,`
	`1414`	`+options=None):`
	`1415`	`+"""`
	`1416`	`+ Do pgbench command and wait.`
	`1417`	`+`
	`1418`	`+ Args:`
	`1419`	`+ dbname: database name to connect to.`
	`1420`	`+ username: database user name.`
	`1421`	`+ stdout: stdout file to be used by Popen.`
	`1422`	`+ stderr: stderr file to be used by Popen.`
	`1423`	`+ options: additional options for pgbench (list).`
	`1424`	`+ """`
	`1425`	`+ifoptionsisNone:`
	`1426`	`+options= []`
	`1427`	`+`
	`1428`	`+withself.pgbench(dbname,username,stdout,stderr,options)aspgbench:`
	`1429`	`+pgbench.wait()`
	`1430`	`+return`
	`1431`	`+`
`1407`	`1432`	`defpgbench_init(self,**kwargs):`
`1408`	`1433`	`"""`
`1409`	`1434`	`Small wrapper for pgbench_run().`

Comments

(0)