[Python-checkins] cpython (3.4): asyncio: Truncate to 80 columns
victor.stinner
python-checkins at python.org
Fri Jan 9 00:11:33 CET 2015
https://hg.python.org/cpython/rev/756d09136a2c
changeset: 94080:756d09136a2c
branch: 3.4
parent: 94078:f12b845a46c0
user: Victor Stinner <victor.stinner at gmail.com>
date: Fri Jan 09 00:09:10 2015 +0100
summary:
asyncio: Truncate to 80 columns
files:
Lib/asyncio/base_events.py | 4 +-
Lib/asyncio/coroutines.py | 12 +++-
Lib/asyncio/selector_events.py | 7 +-
Lib/asyncio/tasks.py | 2 +-
Lib/asyncio/unix_events.py | 3 +-
Lib/asyncio/windows_events.py | 3 +-
Lib/asyncio/windows_utils.py | 7 +-
Lib/test/test_asyncio/test_base_events.py | 9 ++-
Lib/test/test_asyncio/test_futures.py | 24 +++++++---
Lib/test/test_asyncio/test_streams.py | 6 +-
Lib/test/test_asyncio/test_subprocess.py | 4 +-
Lib/test/test_asyncio/test_tasks.py | 12 +++-
12 files changed, 60 insertions(+), 33 deletions(-)
diff --git a/Lib/asyncio/base_events.py b/Lib/asyncio/base_events.py
--- a/Lib/asyncio/base_events.py
+++ b/Lib/asyncio/base_events.py
@@ -201,8 +201,8 @@
"""Create socket transport."""
raise NotImplementedError
- def _make_ssl_transport(self, rawsock, protocol, sslcontext, waiter=None, *,
- server_side=False, server_hostname=None,
+ def _make_ssl_transport(self, rawsock, protocol, sslcontext, waiter=None,
+ *, server_side=False, server_hostname=None,
extra=None, server=None):
"""Create SSL transport."""
raise NotImplementedError
diff --git a/Lib/asyncio/coroutines.py b/Lib/asyncio/coroutines.py
--- a/Lib/asyncio/coroutines.py
+++ b/Lib/asyncio/coroutines.py
@@ -182,14 +182,18 @@
and not inspect.isgeneratorfunction(coro.func)):
filename, lineno = events._get_function_source(coro.func)
if coro.gi_frame is None:
- coro_repr = '%s() done, defined at %s:%s' % (coro_name, filename, lineno)
+ coro_repr = ('%s() done, defined at %s:%s'
+ % (coro_name, filename, lineno))
else:
- coro_repr = '%s() running, defined at %s:%s' % (coro_name, filename, lineno)
+ coro_repr = ('%s() running, defined at %s:%s'
+ % (coro_name, filename, lineno))
elif coro.gi_frame is not None:
lineno = coro.gi_frame.f_lineno
- coro_repr = '%s() running at %s:%s' % (coro_name, filename, lineno)
+ coro_repr = ('%s() running at %s:%s'
+ % (coro_name, filename, lineno))
else:
lineno = coro.gi_code.co_firstlineno
- coro_repr = '%s() done, defined at %s:%s' % (coro_name, filename, lineno)
+ coro_repr = ('%s() done, defined at %s:%s'
+ % (coro_name, filename, lineno))
return coro_repr
diff --git a/Lib/asyncio/selector_events.py b/Lib/asyncio/selector_events.py
--- a/Lib/asyncio/selector_events.py
+++ b/Lib/asyncio/selector_events.py
@@ -55,8 +55,8 @@
return _SelectorSocketTransport(self, sock, protocol, waiter,
extra, server)
- def _make_ssl_transport(self, rawsock, protocol, sslcontext, waiter=None, *,
- server_side=False, server_hostname=None,
+ def _make_ssl_transport(self, rawsock, protocol, sslcontext, waiter=None,
+ *, server_side=False, server_hostname=None,
extra=None, server=None):
return _SelectorSslTransport(
self, rawsock, protocol, sslcontext, waiter,
@@ -484,7 +484,8 @@
info.append('read=idle')
polling = _test_selector_event(self._loop._selector,
- self._sock_fd, selectors.EVENT_WRITE)
+ self._sock_fd,
+ selectors.EVENT_WRITE)
if polling:
state = 'polling'
else:
diff --git a/Lib/asyncio/tasks.py b/Lib/asyncio/tasks.py
--- a/Lib/asyncio/tasks.py
+++ b/Lib/asyncio/tasks.py
@@ -68,7 +68,7 @@
return {t for t in cls._all_tasks if t._loop is loop}
def __init__(self, coro, *, loop=None):
- assert coroutines.iscoroutine(coro), repr(coro) # Not a coroutine function!
+ assert coroutines.iscoroutine(coro), repr(coro)
super().__init__(loop=loop)
if self._source_traceback:
del self._source_traceback[-1]
diff --git a/Lib/asyncio/unix_events.py b/Lib/asyncio/unix_events.py
--- a/Lib/asyncio/unix_events.py
+++ b/Lib/asyncio/unix_events.py
@@ -69,7 +69,8 @@
"""
if (coroutines.iscoroutine(callback)
or coroutines.iscoroutinefunction(callback)):
- raise TypeError("coroutines cannot be used with add_signal_handler()")
+ raise TypeError("coroutines cannot be used "
+ "with add_signal_handler()")
self._check_signal(sig)
self._check_closed()
try:
diff --git a/Lib/asyncio/windows_events.py b/Lib/asyncio/windows_events.py
--- a/Lib/asyncio/windows_events.py
+++ b/Lib/asyncio/windows_events.py
@@ -424,7 +424,8 @@
else:
return windows_utils.PipeHandle(handle)
- return self._register(ov, None, finish_connect_pipe, wait_for_post=True)
+ return self._register(ov, None, finish_connect_pipe,
+ wait_for_post=True)
def wait_for_handle(self, handle, timeout=None):
"""Wait for a handle.
diff --git a/Lib/asyncio/windows_utils.py b/Lib/asyncio/windows_utils.py
--- a/Lib/asyncio/windows_utils.py
+++ b/Lib/asyncio/windows_utils.py
@@ -36,15 +36,16 @@
def socketpair(family=socket.AF_INET, type=socket.SOCK_STREAM, proto=0):
"""A socket pair usable as a self-pipe, for Windows.
- Origin: https://gist.github.com/4325783, by Geert Jansen. Public domain.
+ Origin: https://gist.github.com/4325783, by Geert Jansen.
+ Public domain.
"""
if family == socket.AF_INET:
host = '127.0.0.1'
elif family == socket.AF_INET6:
host = '::1'
else:
- raise ValueError("Only AF_INET and AF_INET6 socket address families "
- "are supported")
+ raise ValueError("Only AF_INET and AF_INET6 socket address "
+ "families are supported")
if type != socket.SOCK_STREAM:
raise ValueError("Only SOCK_STREAM socket type is supported")
if proto != 0:
diff --git a/Lib/test/test_asyncio/test_base_events.py b/Lib/test/test_asyncio/test_base_events.py
--- a/Lib/test/test_asyncio/test_base_events.py
+++ b/Lib/test/test_asyncio/test_base_events.py
@@ -285,7 +285,8 @@
@mock.patch('asyncio.base_events.logger')
def test__run_once_logging(self, m_logger):
def slow_select(timeout):
- # Sleep a bit longer than a second to avoid timer resolution issues.
+ # Sleep a bit longer than a second to avoid timer resolution
+ # issues.
time.sleep(1.1)
return []
@@ -1217,14 +1218,16 @@
self.loop.run_forever()
fmt, *args = m_logger.warning.call_args[0]
self.assertRegex(fmt % tuple(args),
- "^Executing <Handle.*stop_loop_cb.*> took .* seconds$")
+ "^Executing <Handle.*stop_loop_cb.*> "
+ "took .* seconds$")
# slow task
asyncio.async(stop_loop_coro(self.loop), loop=self.loop)
self.loop.run_forever()
fmt, *args = m_logger.warning.call_args[0]
self.assertRegex(fmt % tuple(args),
- "^Executing <Task.*stop_loop_coro.*> took .* seconds$")
+ "^Executing <Task.*stop_loop_coro.*> "
+ "took .* seconds$")
if __name__ == '__main__':
diff --git a/Lib/test/test_asyncio/test_futures.py b/Lib/test/test_asyncio/test_futures.py
--- a/Lib/test/test_asyncio/test_futures.py
+++ b/Lib/test/test_asyncio/test_futures.py
@@ -133,7 +133,8 @@
exc = RuntimeError()
f_exception = asyncio.Future(loop=self.loop)
f_exception.set_exception(exc)
- self.assertEqual(repr(f_exception), '<Future finished exception=RuntimeError()>')
+ self.assertEqual(repr(f_exception),
+ '<Future finished exception=RuntimeError()>')
self.assertIs(f_exception.exception(), exc)
def func_repr(func):
@@ -332,16 +333,21 @@
if debug:
frame = source_traceback[-1]
regex = (r'^Future exception was never retrieved\n'
- r'future: <Future finished exception=MemoryError\(\) created at {filename}:{lineno}>\n'
- r'source_traceback: Object created at \(most recent call last\):\n'
+ r'future: <Future finished exception=MemoryError\(\) '
+ r'created at {filename}:{lineno}>\n'
+ r'source_traceback: Object '
+ r'created at \(most recent call last\):\n'
r' File'
r'.*\n'
- r' File "{filename}", line {lineno}, in check_future_exception_never_retrieved\n'
+ r' File "{filename}", line {lineno}, '
+ r'in check_future_exception_never_retrieved\n'
r' future = asyncio\.Future\(loop=self\.loop\)$'
- ).format(filename=re.escape(frame[0]), lineno=frame[1])
+ ).format(filename=re.escape(frame[0]),
+ lineno=frame[1])
else:
regex = (r'^Future exception was never retrieved\n'
- r'future: <Future finished exception=MemoryError\(\)>$'
+ r'future: '
+ r'<Future finished exception=MemoryError\(\)>$'
)
exc_info = (type(exc), exc, exc.__traceback__)
m_log.error.assert_called_once_with(mock.ANY, exc_info=exc_info)
@@ -352,12 +358,14 @@
r'Future/Task created at \(most recent call last\):\n'
r' File'
r'.*\n'
- r' File "{filename}", line {lineno}, in check_future_exception_never_retrieved\n'
+ r' File "{filename}", line {lineno}, '
+ r'in check_future_exception_never_retrieved\n'
r' future = asyncio\.Future\(loop=self\.loop\)\n'
r'Traceback \(most recent call last\):\n'
r'.*\n'
r'MemoryError$'
- ).format(filename=re.escape(frame[0]), lineno=frame[1])
+ ).format(filename=re.escape(frame[0]),
+ lineno=frame[1])
else:
regex = (r'^Future/Task exception was never retrieved\n'
r'Traceback \(most recent call last\):\n'
diff --git a/Lib/test/test_asyncio/test_streams.py b/Lib/test/test_asyncio/test_streams.py
--- a/Lib/test/test_asyncio/test_streams.py
+++ b/Lib/test/test_asyncio/test_streams.py
@@ -613,8 +613,10 @@
watcher.attach_loop(self.loop)
try:
asyncio.set_child_watcher(watcher)
- proc = self.loop.run_until_complete(
- asyncio.create_subprocess_exec(*args, pass_fds={wfd}, loop=self.loop))
+ create = asyncio.create_subprocess_exec(*args,
+ pass_fds={wfd},
+ loop=self.loop)
+ proc = self.loop.run_until_complete(create)
self.loop.run_until_complete(proc.wait())
finally:
asyncio.set_child_watcher(None)
diff --git a/Lib/test/test_asyncio/test_subprocess.py b/Lib/test/test_asyncio/test_subprocess.py
--- a/Lib/test/test_asyncio/test_subprocess.py
+++ b/Lib/test/test_asyncio/test_subprocess.py
@@ -115,7 +115,9 @@
def test_send_signal(self):
code = 'import time; print("sleeping", flush=True); time.sleep(3600)'
args = [sys.executable, '-c', code]
- create = asyncio.create_subprocess_exec(*args, loop=self.loop, stdout=subprocess.PIPE)
+ create = asyncio.create_subprocess_exec(*args,
+ stdout=subprocess.PIPE,
+ loop=self.loop)
proc = self.loop.run_until_complete(create)
@asyncio.coroutine
diff --git a/Lib/test/test_asyncio/test_tasks.py b/Lib/test/test_asyncio/test_tasks.py
--- a/Lib/test/test_asyncio/test_tasks.py
+++ b/Lib/test/test_asyncio/test_tasks.py
@@ -208,7 +208,8 @@
self.assertEqual(notmuch.__name__, 'notmuch')
if PY35:
self.assertEqual(notmuch.__qualname__,
- 'TaskTests.test_task_repr_coro_decorator.<locals>.notmuch')
+ 'TaskTests.test_task_repr_coro_decorator'
+ '.<locals>.notmuch')
self.assertEqual(notmuch.__module__, __name__)
# test coroutine object
@@ -218,7 +219,8 @@
# function, as expected, and have a qualified name (__qualname__
# attribute).
coro_name = 'notmuch'
- coro_qualname = 'TaskTests.test_task_repr_coro_decorator.<locals>.notmuch'
+ coro_qualname = ('TaskTests.test_task_repr_coro_decorator'
+ '.<locals>.notmuch')
else:
# On Python < 3.5, generators inherit the name of the code, not of
# the function. See: http://bugs.python.org/issue21205
@@ -239,7 +241,8 @@
else:
code = gen.gi_code
coro = ('%s() running at %s:%s'
- % (coro_qualname, code.co_filename, code.co_firstlineno))
+ % (coro_qualname, code.co_filename,
+ code.co_firstlineno))
self.assertEqual(repr(gen), '<CoroWrapper %s>' % coro)
@@ -1678,7 +1681,8 @@
self.assertTrue(m_log.error.called)
message = m_log.error.call_args[0][0]
func_filename, func_lineno = test_utils.get_function_source(coro_noop)
- regex = (r'^<CoroWrapper %s\(\) .* at %s:%s, .*> was never yielded from\n'
+ regex = (r'^<CoroWrapper %s\(\) .* at %s:%s, .*> '
+ r'was never yielded from\n'
r'Coroutine object created at \(most recent call last\):\n'
r'.*\n'
r' File "%s", line %s, in test_coroutine_never_yielded\n'
--
Repository URL: https://hg.python.org/cpython
More information about the Python-checkins
mailing list