diff options
author | Daniele Varrazzo <daniele.varrazzo@gmail.com> | 2017-02-03 04:56:02 +0000 |
---|---|---|
committer | Daniele Varrazzo <daniele.varrazzo@gmail.com> | 2017-02-03 04:56:02 +0000 |
commit | de8b335d80ecba0305e2b4796373a4064fd450b3 (patch) | |
tree | 26a5fab1a9f022adda5d5ad2de78b816fe0350e1 /tests/test_notify.py | |
parent | a8a3a298f8ade3b0430ff2df0a5d5ee1fe920e3d (diff) | |
parent | ca42306d7916647448184907e03c77ff54ebd4f9 (diff) | |
download | psycopg2-sql-compose.tar.gz |
Merge branch 'master' into sql-composesql-compose
Diffstat (limited to 'tests/test_notify.py')
-rwxr-xr-x | tests/test_notify.py | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/tests/test_notify.py b/tests/test_notify.py index 1a0ac45..0e74e1d 100755 --- a/tests/test_notify.py +++ b/tests/test_notify.py @@ -26,7 +26,7 @@ from testutils import unittest import psycopg2 from psycopg2 import extensions -from testutils import ConnectingTestCase, script_to_py3 +from testutils import ConnectingTestCase, script_to_py3, slow from testconfig import dsn import sys @@ -72,6 +72,7 @@ conn.close() return Popen([sys.executable, '-c', script_to_py3(script)], stdout=PIPE) + @slow def test_notifies_received_on_poll(self): self.autocommit(self.conn) self.listen('foo') @@ -90,6 +91,7 @@ conn.close() self.assertEqual(pid, self.conn.notifies[0][0]) self.assertEqual('foo', self.conn.notifies[0][1]) + @slow def test_many_notifies(self): self.autocommit(self.conn) for name in ['foo', 'bar', 'baz']: @@ -109,6 +111,7 @@ conn.close() self.assertEqual(pids[name], pid) names.pop(name) # raise if name found twice + @slow def test_notifies_received_on_execute(self): self.autocommit(self.conn) self.listen('foo') @@ -119,6 +122,7 @@ conn.close() self.assertEqual(pid, self.conn.notifies[0][0]) self.assertEqual('foo', self.conn.notifies[0][1]) + @slow def test_notify_object(self): self.autocommit(self.conn) self.listen('foo') @@ -128,6 +132,7 @@ conn.close() notify = self.conn.notifies[0] self.assert_(isinstance(notify, psycopg2.extensions.Notify)) + @slow def test_notify_attributes(self): self.autocommit(self.conn) self.listen('foo') @@ -140,6 +145,7 @@ conn.close() self.assertEqual('foo', notify.channel) self.assertEqual('', notify.payload) + @slow def test_notify_payload(self): if self.conn.server_version < 90000: return self.skipTest("server version %s doesn't support notify payload" @@ -155,6 +161,7 @@ conn.close() self.assertEqual('foo', notify.channel) self.assertEqual('Hello, world!', notify.payload) + @slow def test_notify_deque(self): from collections import deque self.autocommit(self.conn) @@ -167,6 +174,7 @@ conn.close() self.assert_(isinstance(notify, psycopg2.extensions.Notify)) self.assertEqual(len(self.conn.notifies), 0) + @slow def test_notify_noappend(self): self.autocommit(self.conn) self.conn.notifies = None |