from txpostgres import txpostgres pool = txpostgres.ConnectionPool( "dbname=mydatabase user=myuser password=mypassword host=localhost" ) def handleResult(result): print(result) def handleError(error): print("Error:", error) d = pool.runQuery("SELECT * FROM mytable") d.addCallbacks(handleResult, handleError) def transaction(conn): result1 = conn.runQuery("SELECT * FROM table1") result2 = conn.runQuery("SELECT * FROM table2 WHERE column='value'") return defer.gatherResults([result1, result2]) d = pool.runInteraction(transaction) d.addCallbacks(handleResult, handleError)