Jun 1, 2018 · Mar 16, 2018 · Mar 16, 2018 · Mar 16, 2018 · Mar 19, 2018 · Mar 22, 2018
diff --git a/testgres/pubsub.py b/testgres/pubsub.py
 # coding: utf-8

 from six import raise_from
 from six import raise_from, iteritems

 from .defaults import default_dbname, default_username
 from .exceptions import CatchUpException

        # additional parameters
        if kwargs:
            params = ','.join('{}={}'.format(k, v) for k, v inkwargs.iteritems())
            params = ','.join('{}={}'.format(k, v) for k, v in iteritems(kwargs))
            query += " with ({})".format(params)

        node.safe_psql(query, dbname=dbname, username=username)
Original file line number	Diff line number	Diff line change
		@@ -1,6 +1,6 @@
		# coding: utf-8

		from six import raise_from
		from six import raise_from, iteritems

		from .defaults import default_dbname, default_username
		from .exceptions import CatchUpException
Expand DownExpand Up		@@ -92,7 +92,7 @@ def __init__(self,

		# additional parameters
		if kwargs:
		params = ','.join('{}={}'.format(k, v) for k, v inkwargs.iteritems())
		params = ','.join('{}={}'.format(k, v) for k, v in iteritems(kwargs))
		query += " with ({})".format(params)

		node.safe_psql(query, dbname=dbname, username=username)
Expand Down