diff options
author | Daniele Varrazzo <daniele.varrazzo@gmail.com> | 2017-02-03 04:45:17 +0000 |
---|---|---|
committer | Daniele Varrazzo <daniele.varrazzo@gmail.com> | 2017-02-03 04:45:17 +0000 |
commit | 1911b250e33e140bbbc25f3536bda24e8ca35bdb (patch) | |
tree | c18202b036fb5e5570c3556e852efae9a4dee76e /tests/test_async.py | |
parent | 6e89db020ca9fd93260bfff7aadef64dd4535553 (diff) | |
parent | 44c3b776917444ca98667f5d6f4470c767f820bf (diff) | |
download | psycopg2-1911b250e33e140bbbc25f3536bda24e8ca35bdb.tar.gz |
Merge branch 'async-keyword'
Close #495
Diffstat (limited to 'tests/test_async.py')
-rwxr-xr-x | tests/test_async.py | 16 |
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", |