__all__ = ['Task',
'FIRST_COMPLETED', 'FIRST_EXCEPTION', 'ALL_COMPLETED',
'wait', 'wait_for', 'as_completed', 'sleep', 'async',
- 'gather', 'shield',
+ 'gather', 'shield', 'ensure_future',
]
import concurrent.futures
import linecache
import sys
import traceback
+import warnings
import weakref
from . import coroutines
if loop is None:
loop = events.get_event_loop()
- fs = {async(f, loop=loop) for f in set(fs)}
+ fs = {ensure_future(f, loop=loop) for f in set(fs)}
return (yield from _wait(fs, timeout, return_when, loop))
timeout_handle = loop.call_later(timeout, _release_waiter, waiter)
cb = functools.partial(_release_waiter, waiter)
- fut = async(fut, loop=loop)
+ fut = ensure_future(fut, loop=loop)
fut.add_done_callback(cb)
try:
if isinstance(fs, futures.Future) or coroutines.iscoroutine(fs):
raise TypeError("expect a list of futures, not %s" % type(fs).__name__)
loop = loop if loop is not None else events.get_event_loop()
- todo = {async(f, loop=loop) for f in set(fs)}
+ todo = {ensure_future(f, loop=loop) for f in set(fs)}
from .queues import Queue # Import here to avoid circular import problem.
done = Queue(loop=loop)
timeout_handle = None
def async(coro_or_future, *, loop=None):
"""Wrap a coroutine in a future.
+ If the argument is a Future, it is returned directly.
+
+ This function is deprecated in 3.5. Use asyncio.ensure_future() instead.
+ """
+
+ warnings.warn("asyncio.async() function is deprecated, use ensure_future()",
+ DeprecationWarning)
+
+ return ensure_future(coro_or_future, loop=loop)
+
+
+def ensure_future(coro_or_future, *, loop=None):
+ """Wrap a coroutine in a future.
+
If the argument is a Future, it is returned directly.
"""
if isinstance(coro_or_future, futures.Future):
arg_to_fut = {}
for arg in set(coros_or_futures):
if not isinstance(arg, futures.Future):
- fut = async(arg, loop=loop)
+ fut = ensure_future(arg, loop=loop)
if loop is None:
loop = fut._loop
# The caller cannot control this future, the "destroy pending task"
except CancelledError:
res = None
"""
- inner = async(arg, loop=loop)
+ inner = ensure_future(arg, loop=loop)
if inner.done():
# Shortcut.
return inner
loop.run_until_complete(t)
loop.close()
- def test_async_coroutine(self):
+ def test_ensure_future_coroutine(self):
@asyncio.coroutine
def notmuch():
return 'ok'
- t = asyncio.async(notmuch(), loop=self.loop)
+ t = asyncio.ensure_future(notmuch(), loop=self.loop)
self.loop.run_until_complete(t)
self.assertTrue(t.done())
self.assertEqual(t.result(), 'ok')
loop = asyncio.new_event_loop()
self.set_event_loop(loop)
- t = asyncio.async(notmuch(), loop=loop)
+ t = asyncio.ensure_future(notmuch(), loop=loop)
self.assertIs(t._loop, loop)
loop.run_until_complete(t)
loop.close()
- def test_async_future(self):
+ def test_ensure_future_future(self):
f_orig = asyncio.Future(loop=self.loop)
f_orig.set_result('ko')
- f = asyncio.async(f_orig)
+ f = asyncio.ensure_future(f_orig)
self.loop.run_until_complete(f)
self.assertTrue(f.done())
self.assertEqual(f.result(), 'ko')
self.set_event_loop(loop)
with self.assertRaises(ValueError):
- f = asyncio.async(f_orig, loop=loop)
+ f = asyncio.ensure_future(f_orig, loop=loop)
loop.close()
- f = asyncio.async(f_orig, loop=self.loop)
+ f = asyncio.ensure_future(f_orig, loop=self.loop)
self.assertIs(f, f_orig)
- def test_async_task(self):
+ def test_ensure_future_task(self):
@asyncio.coroutine
def notmuch():
return 'ok'
t_orig = asyncio.Task(notmuch(), loop=self.loop)
- t = asyncio.async(t_orig)
+ t = asyncio.ensure_future(t_orig)
self.loop.run_until_complete(t)
self.assertTrue(t.done())
self.assertEqual(t.result(), 'ok')
self.set_event_loop(loop)
with self.assertRaises(ValueError):
- t = asyncio.async(t_orig, loop=loop)
+ t = asyncio.ensure_future(t_orig, loop=loop)
loop.close()
- t = asyncio.async(t_orig, loop=self.loop)
+ t = asyncio.ensure_future(t_orig, loop=self.loop)
self.assertIs(t, t_orig)
- def test_async_neither(self):
+ def test_ensure_future_neither(self):
with self.assertRaises(TypeError):
- asyncio.async('ok')
+ asyncio.ensure_future('ok')
+
+ def test_async_warning(self):
+ f = asyncio.Future(loop=self.loop)
+ with self.assertWarnsRegex(DeprecationWarning,
+ 'function is deprecated, use ensure_'):
+ self.assertIs(f, asyncio.async(f))
def test_task_repr(self):
self.loop.set_debug(False)
else:
proof += 10
- f = asyncio.async(outer(), loop=self.loop)
+ f = asyncio.ensure_future(outer(), loop=self.loop)
test_utils.run_briefly(self.loop)
f.cancel()
self.loop.run_until_complete(f)
d, p = yield from asyncio.wait([inner()], loop=self.loop)
proof += 100
- f = asyncio.async(outer(), loop=self.loop)
+ f = asyncio.ensure_future(outer(), loop=self.loop)
test_utils.run_briefly(self.loop)
f.cancel()
self.assertRaises(
yield from asyncio.shield(inner(), loop=self.loop)
proof += 100
- f = asyncio.async(outer(), loop=self.loop)
+ f = asyncio.ensure_future(outer(), loop=self.loop)
test_utils.run_briefly(self.loop)
f.cancel()
with self.assertRaises(asyncio.CancelledError):
# schedule the task
coro = kill_me(self.loop)
- task = asyncio.async(coro, loop=self.loop)
+ task = asyncio.ensure_future(coro, loop=self.loop)
self.assertEqual(asyncio.Task.all_tasks(loop=self.loop), {task})
# execute the task so it waits for future
yield from waiter
proof += 1
- child1 = asyncio.async(inner(), loop=self.one_loop)
- child2 = asyncio.async(inner(), loop=self.one_loop)
+ child1 = asyncio.ensure_future(inner(), loop=self.one_loop)
+ child2 = asyncio.ensure_future(inner(), loop=self.one_loop)
gatherer = None
@asyncio.coroutine
yield from gatherer
proof += 100
- f = asyncio.async(outer(), loop=self.one_loop)
+ f = asyncio.ensure_future(outer(), loop=self.one_loop)
test_utils.run_briefly(self.one_loop)
self.assertTrue(f.cancel())
with self.assertRaises(asyncio.CancelledError):
def outer():
yield from asyncio.gather(inner(a), inner(b), loop=self.one_loop)
- f = asyncio.async(outer(), loop=self.one_loop)
+ f = asyncio.ensure_future(outer(), loop=self.one_loop)
test_utils.run_briefly(self.one_loop)
a.set_result(None)
test_utils.run_briefly(self.one_loop)