summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorVictor Stinner <victor.stinner@gmail.com>2014-01-07 00:21:43 +0100
committerVictor Stinner <victor.stinner@gmail.com>2014-01-07 00:21:43 +0100
commit6d8c2cbe675a26d3054bb3b504b9e1fc2023a2f5 (patch)
treee023fbf90c8e06407f7945bca91c2ca5a7bd28f4
parentaedb0546d816a136c5ce14e4d5acacf25eaa9815 (diff)
downloadtrollius-6d8c2cbe675a26d3054bb3b504b9e1fc2023a2f5.tar.gz
Python 2.6 doesn't support dict and set-comprehension
-rw-r--r--asyncio/tasks.py2
-rw-r--r--tests/test_events.py2
-rw-r--r--tests/test_tasks.py20
3 files changed, 12 insertions, 12 deletions
diff --git a/asyncio/tasks.py b/asyncio/tasks.py
index 765798a..10161ad 100644
--- a/asyncio/tasks.py
+++ b/asyncio/tasks.py
@@ -73,7 +73,7 @@ class Task(futures.Future):
"""
if loop is None:
loop = events.get_event_loop()
- return {t for t in cls._all_tasks if t._loop is loop}
+ return set(t for t in cls._all_tasks if t._loop is loop)
def __init__(self, coro, loop=None):
assert iscoroutine(coro), repr(coro) # Not a coroutine function!
diff --git a/tests/test_events.py b/tests/test_events.py
index 2e83884..2e22fd9 100644
--- a/tests/test_events.py
+++ b/tests/test_events.py
@@ -175,7 +175,7 @@ class MySubprocessProtocol(protocols.SubprocessProtocol):
self.transport = None
self.connected = futures.Future(loop=loop)
self.completed = futures.Future(loop=loop)
- self.disconnects = {fd: futures.Future(loop=loop) for fd in range(3)}
+ self.disconnects = dict((fd, futures.Future(loop=loop)) for fd in range(3))
self.data = {1: b'', 2: b''}
self.returncode = None
self.got_data = {1: locks.Event(loop=loop),
diff --git a/tests/test_tasks.py b/tests/test_tasks.py
index 76554c3..9b7e0d9 100644
--- a/tests/test_tasks.py
+++ b/tests/test_tasks.py
@@ -508,8 +508,8 @@ class TaskTests(unittest.TestCase):
loop=loop)
done, pending = loop.run_until_complete(task)
- self.assertEqual({b}, done)
- self.assertEqual({a}, pending)
+ self.assertEqual(set((b,)), done)
+ self.assertEqual(set((a,)), pending)
self.assertFalse(a.done())
self.assertTrue(b.done())
self.assertIsNone(b.result())
@@ -540,7 +540,7 @@ class TaskTests(unittest.TestCase):
loop=self.loop)
done, pending = self.loop.run_until_complete(task)
- self.assertEqual({a, b}, done)
+ self.assertEqual(set((a, b)), done)
self.assertTrue(a.done())
self.assertIsNone(a.result())
self.assertTrue(b.done())
@@ -570,8 +570,8 @@ class TaskTests(unittest.TestCase):
loop=loop)
done, pending = loop.run_until_complete(task)
- self.assertEqual({b}, done)
- self.assertEqual({a}, pending)
+ self.assertEqual(set((b,)), done)
+ self.assertEqual(set((a,)), pending)
self.assertAlmostEqual(0, loop.time())
# move forward to close generator
@@ -603,8 +603,8 @@ class TaskTests(unittest.TestCase):
loop=loop)
done, pending = loop.run_until_complete(task)
- self.assertEqual({b}, done)
- self.assertEqual({a}, pending)
+ self.assertEqual(set((b,)), done)
+ self.assertEqual(set((a,)), pending)
self.assertAlmostEqual(0.01, loop.time())
# move forward to close generator
@@ -801,7 +801,7 @@ class TaskTests(unittest.TestCase):
a = tasks.sleep(0.05, 'a', loop=loop)
b = tasks.sleep(0.10, 'b', loop=loop)
- fs = {a, b}
+ fs = set((a, b))
futs = list(tasks.as_completed(fs, loop=loop))
self.assertEqual(len(futs), 2)
@@ -827,12 +827,12 @@ class TaskTests(unittest.TestCase):
a = tasks.sleep(0.05, 'a', loop=loop)
b = tasks.sleep(0.05, 'b', loop=loop)
- fs = {a, b}
+ fs = set((a, b))
futs = list(tasks.as_completed(fs, loop=loop))
self.assertEqual(len(futs), 2)
waiter = tasks.wait(futs, loop=loop)
done, pending = loop.run_until_complete(waiter)
- self.assertEqual(set(f.result() for f in done), {'a', 'b'})
+ self.assertEqual(set(f.result() for f in done), set(('a', 'b')))
def test_sleep(self):