summaryrefslogtreecommitdiff
path: root/tests/test_async.py
diff options
context:
space:
mode:
authorDaniele Varrazzo <daniele.varrazzo@gmail.com>2017-02-03 04:45:17 +0000
committerDaniele Varrazzo <daniele.varrazzo@gmail.com>2017-02-03 04:45:17 +0000
commit1911b250e33e140bbbc25f3536bda24e8ca35bdb (patch)
treec18202b036fb5e5570c3556e852efae9a4dee76e /tests/test_async.py
parent6e89db020ca9fd93260bfff7aadef64dd4535553 (diff)
parent44c3b776917444ca98667f5d6f4470c767f820bf (diff)
downloadpsycopg2-1911b250e33e140bbbc25f3536bda24e8ca35bdb.tar.gz
Merge branch 'async-keyword'
Close #495
Diffstat (limited to 'tests/test_async.py')
-rwxr-xr-xtests/test_async.py16
1 files changed, 8 insertions, 8 deletions
diff --git a/tests/test_async.py b/tests/test_async.py
index e7fc1a9..63a5513 100755
--- a/tests/test_async.py
+++ b/tests/test_async.py
@@ -55,7 +55,7 @@ class AsyncTests(ConnectingTestCase):
ConnectingTestCase.setUp(self)
self.sync_conn = self.conn
- self.conn = self.connect(async=True)
+ self.conn = self.connect(async_=True)
self.wait(self.conn)
@@ -71,8 +71,8 @@ class AsyncTests(ConnectingTestCase):
sync_cur = self.sync_conn.cursor()
del cur, sync_cur
- self.assert_(self.conn.async)
- self.assert_(not self.sync_conn.async)
+ self.assert_(self.conn.async_)
+ self.assert_(not self.sync_conn.async_)
# the async connection should be in isolevel 0
self.assertEquals(self.conn.isolation_level, 0)
@@ -312,12 +312,12 @@ class AsyncTests(ConnectingTestCase):
def test_async_subclass(self):
class MyConn(psycopg2.extensions.connection):
- def __init__(self, dsn, async=0):
- psycopg2.extensions.connection.__init__(self, dsn, async=async)
+ def __init__(self, dsn, async_=0):
+ psycopg2.extensions.connection.__init__(self, dsn, async_=async_)
- conn = self.connect(connection_factory=MyConn, async=True)
+ conn = self.connect(connection_factory=MyConn, async_=True)
self.assert_(isinstance(conn, MyConn))
- self.assert_(conn.async)
+ self.assert_(conn.async_)
conn.close()
@slow
@@ -441,7 +441,7 @@ class AsyncTests(ConnectingTestCase):
def test_async_connection_error_message(self):
try:
- cnn = psycopg2.connect('dbname=thisdatabasedoesntexist', async=True)
+ cnn = psycopg2.connect('dbname=thisdatabasedoesntexist', async_=True)
self.wait(cnn)
except psycopg2.Error, e:
self.assertNotEqual(str(e), "asynchronous connection failed",