mirror of
https://github.com/python/cpython.git
synced 2024-11-23 18:04:37 +08:00
[3.9] bpo-37116: Use PEP 570 syntax for positional-only parameters. (GH-12620)
Turn deprecation warnings added in 3.8 into TypeError.
This commit is contained in:
parent
6c01ebcc0d
commit
142566c028
@ -343,7 +343,7 @@ The :mod:`bdb` module also defines two classes:
|
|||||||
|
|
||||||
For backwards compatibility. Calls the :meth:`run` method.
|
For backwards compatibility. Calls the :meth:`run` method.
|
||||||
|
|
||||||
.. method:: runcall(func, *args, **kwds)
|
.. method:: runcall(func, /, *args, **kwds)
|
||||||
|
|
||||||
Debug a single function call, and return its result.
|
Debug a single function call, and return its result.
|
||||||
|
|
||||||
|
@ -28,7 +28,7 @@ Executor Objects
|
|||||||
An abstract class that provides methods to execute calls asynchronously. It
|
An abstract class that provides methods to execute calls asynchronously. It
|
||||||
should not be used directly, but through its concrete subclasses.
|
should not be used directly, but through its concrete subclasses.
|
||||||
|
|
||||||
.. method:: submit(fn, *args, **kwargs)
|
.. method:: submit(fn, /, *args, **kwargs)
|
||||||
|
|
||||||
Schedules the callable, *fn*, to be executed as ``fn(*args **kwargs)``
|
Schedules the callable, *fn*, to be executed as ``fn(*args **kwargs)``
|
||||||
and returns a :class:`Future` object representing the execution of the
|
and returns a :class:`Future` object representing the execution of the
|
||||||
|
@ -416,7 +416,7 @@ Functions and classes provided:
|
|||||||
The passed in object is returned from the function, allowing this
|
The passed in object is returned from the function, allowing this
|
||||||
method to be used as a function decorator.
|
method to be used as a function decorator.
|
||||||
|
|
||||||
.. method:: callback(callback, *args, **kwds)
|
.. method:: callback(callback, /, *args, **kwds)
|
||||||
|
|
||||||
Accepts an arbitrary callback function and arguments and adds it to
|
Accepts an arbitrary callback function and arguments and adds it to
|
||||||
the callback stack.
|
the callback stack.
|
||||||
@ -473,7 +473,7 @@ Functions and classes provided:
|
|||||||
Similar to :meth:`push` but expects either an asynchronous context manager
|
Similar to :meth:`push` but expects either an asynchronous context manager
|
||||||
or a coroutine function.
|
or a coroutine function.
|
||||||
|
|
||||||
.. method:: push_async_callback(callback, *args, **kwds)
|
.. method:: push_async_callback(callback, /, *args, **kwds)
|
||||||
|
|
||||||
Similar to :meth:`callback` but expects a coroutine function.
|
Similar to :meth:`callback` but expects a coroutine function.
|
||||||
|
|
||||||
|
@ -656,7 +656,7 @@ The module :mod:`curses` defines the following functions:
|
|||||||
foreground color on the default background.
|
foreground color on the default background.
|
||||||
|
|
||||||
|
|
||||||
.. function:: wrapper(func, ...)
|
.. function:: wrapper(func, /, *args, **kwargs)
|
||||||
|
|
||||||
Initialize curses and call another callable object, *func*, which should be the
|
Initialize curses and call another callable object, *func*, which should be the
|
||||||
rest of your curses-using application. If the application raises an exception,
|
rest of your curses-using application. If the application raises an exception,
|
||||||
|
@ -309,7 +309,7 @@ functions:
|
|||||||
Profile the cmd via :func:`exec` with the specified global and
|
Profile the cmd via :func:`exec` with the specified global and
|
||||||
local environment.
|
local environment.
|
||||||
|
|
||||||
.. method:: runcall(func, *args, **kwargs)
|
.. method:: runcall(func, /, *args, **kwargs)
|
||||||
|
|
||||||
Profile ``func(*args, **kwargs)``
|
Profile ``func(*args, **kwargs)``
|
||||||
|
|
||||||
|
@ -166,7 +166,7 @@ Programmatic Interface
|
|||||||
environments. If not defined, *globals* and *locals* default to empty
|
environments. If not defined, *globals* and *locals* default to empty
|
||||||
dictionaries.
|
dictionaries.
|
||||||
|
|
||||||
.. method:: runfunc(func, *args, **kwds)
|
.. method:: runfunc(func, /, *args, **kwds)
|
||||||
|
|
||||||
Call *func* with the given arguments under control of the :class:`Trace`
|
Call *func* with the given arguments under control of the :class:`Trace`
|
||||||
object with the current tracing parameters.
|
object with the current tracing parameters.
|
||||||
|
@ -1427,7 +1427,7 @@ Test cases
|
|||||||
:class:`TextTestResult` in Python 3.2.
|
:class:`TextTestResult` in Python 3.2.
|
||||||
|
|
||||||
|
|
||||||
.. method:: addCleanup(function, *args, **kwargs)
|
.. method:: addCleanup(function, /, *args, **kwargs)
|
||||||
|
|
||||||
Add a function to be called after :meth:`tearDown` to cleanup resources
|
Add a function to be called after :meth:`tearDown` to cleanup resources
|
||||||
used during the test. Functions will be called in reverse order to the
|
used during the test. Functions will be called in reverse order to the
|
||||||
|
@ -240,7 +240,7 @@ objects.
|
|||||||
|
|
||||||
.. versionadded:: 3.4
|
.. versionadded:: 3.4
|
||||||
|
|
||||||
.. class:: finalize(obj, func, *args, **kwargs)
|
.. class:: finalize(obj, func, /, *args, **kwargs)
|
||||||
|
|
||||||
Return a callable finalizer object which will be called when *obj*
|
Return a callable finalizer object which will be called when *obj*
|
||||||
is garbage collected. Unlike an ordinary weak reference, a finalizer
|
is garbage collected. Unlike an ordinary weak reference, a finalizer
|
||||||
|
18
Lib/bdb.py
18
Lib/bdb.py
@ -618,26 +618,11 @@ class Bdb:
|
|||||||
|
|
||||||
# This method is more useful to debug a single function call.
|
# This method is more useful to debug a single function call.
|
||||||
|
|
||||||
def runcall(*args, **kwds):
|
def runcall(self, func, /, *args, **kwds):
|
||||||
"""Debug a single function call.
|
"""Debug a single function call.
|
||||||
|
|
||||||
Return the result of the function call.
|
Return the result of the function call.
|
||||||
"""
|
"""
|
||||||
if len(args) >= 2:
|
|
||||||
self, func, *args = args
|
|
||||||
elif not args:
|
|
||||||
raise TypeError("descriptor 'runcall' of 'Bdb' object "
|
|
||||||
"needs an argument")
|
|
||||||
elif 'func' in kwds:
|
|
||||||
func = kwds.pop('func')
|
|
||||||
self, *args = args
|
|
||||||
import warnings
|
|
||||||
warnings.warn("Passing 'func' as keyword argument is deprecated",
|
|
||||||
DeprecationWarning, stacklevel=2)
|
|
||||||
else:
|
|
||||||
raise TypeError('runcall expected at least 1 positional argument, '
|
|
||||||
'got %d' % (len(args)-1))
|
|
||||||
|
|
||||||
self.reset()
|
self.reset()
|
||||||
sys.settrace(self.trace_dispatch)
|
sys.settrace(self.trace_dispatch)
|
||||||
res = None
|
res = None
|
||||||
@ -649,7 +634,6 @@ class Bdb:
|
|||||||
self.quitting = True
|
self.quitting = True
|
||||||
sys.settrace(None)
|
sys.settrace(None)
|
||||||
return res
|
return res
|
||||||
runcall.__text_signature__ = '($self, func, /, *args, **kwds)'
|
|
||||||
|
|
||||||
|
|
||||||
def set_trace():
|
def set_trace():
|
||||||
|
@ -103,28 +103,12 @@ class Profile(_lsprof.Profiler):
|
|||||||
return self
|
return self
|
||||||
|
|
||||||
# This method is more useful to profile a single function call.
|
# This method is more useful to profile a single function call.
|
||||||
def runcall(*args, **kw):
|
def runcall(self, func, /, *args, **kw):
|
||||||
if len(args) >= 2:
|
|
||||||
self, func, *args = args
|
|
||||||
elif not args:
|
|
||||||
raise TypeError("descriptor 'runcall' of 'Profile' object "
|
|
||||||
"needs an argument")
|
|
||||||
elif 'func' in kw:
|
|
||||||
func = kw.pop('func')
|
|
||||||
self, *args = args
|
|
||||||
import warnings
|
|
||||||
warnings.warn("Passing 'func' as keyword argument is deprecated",
|
|
||||||
DeprecationWarning, stacklevel=2)
|
|
||||||
else:
|
|
||||||
raise TypeError('runcall expected at least 1 positional argument, '
|
|
||||||
'got %d' % (len(args)-1))
|
|
||||||
|
|
||||||
self.enable()
|
self.enable()
|
||||||
try:
|
try:
|
||||||
return func(*args, **kw)
|
return func(*args, **kw)
|
||||||
finally:
|
finally:
|
||||||
self.disable()
|
self.disable()
|
||||||
runcall.__text_signature__ = '($self, func, /, *args, **kw)'
|
|
||||||
|
|
||||||
def __enter__(self):
|
def __enter__(self):
|
||||||
self.enable()
|
self.enable()
|
||||||
|
@ -971,28 +971,12 @@ class ChainMap(_collections_abc.MutableMapping):
|
|||||||
class UserDict(_collections_abc.MutableMapping):
|
class UserDict(_collections_abc.MutableMapping):
|
||||||
|
|
||||||
# Start by filling-out the abstract methods
|
# Start by filling-out the abstract methods
|
||||||
def __init__(*args, **kwargs):
|
def __init__(self, dict=None, /, **kwargs):
|
||||||
if not args:
|
|
||||||
raise TypeError("descriptor '__init__' of 'UserDict' object "
|
|
||||||
"needs an argument")
|
|
||||||
self, *args = args
|
|
||||||
if len(args) > 1:
|
|
||||||
raise TypeError('expected at most 1 arguments, got %d' % len(args))
|
|
||||||
if args:
|
|
||||||
dict = args[0]
|
|
||||||
elif 'dict' in kwargs:
|
|
||||||
dict = kwargs.pop('dict')
|
|
||||||
import warnings
|
|
||||||
warnings.warn("Passing 'dict' as keyword argument is deprecated",
|
|
||||||
DeprecationWarning, stacklevel=2)
|
|
||||||
else:
|
|
||||||
dict = None
|
|
||||||
self.data = {}
|
self.data = {}
|
||||||
if dict is not None:
|
if dict is not None:
|
||||||
self.update(dict)
|
self.update(dict)
|
||||||
if kwargs:
|
if kwargs:
|
||||||
self.update(kwargs)
|
self.update(kwargs)
|
||||||
__init__.__text_signature__ = '($self, dict=None, /, **kwargs)'
|
|
||||||
|
|
||||||
def __len__(self): return len(self.data)
|
def __len__(self): return len(self.data)
|
||||||
def __getitem__(self, key):
|
def __getitem__(self, key):
|
||||||
|
@ -547,7 +547,7 @@ class Future(object):
|
|||||||
class Executor(object):
|
class Executor(object):
|
||||||
"""This is an abstract base class for concrete asynchronous executors."""
|
"""This is an abstract base class for concrete asynchronous executors."""
|
||||||
|
|
||||||
def submit(*args, **kwargs):
|
def submit(self, fn, /, *args, **kwargs):
|
||||||
"""Submits a callable to be executed with the given arguments.
|
"""Submits a callable to be executed with the given arguments.
|
||||||
|
|
||||||
Schedules the callable to be executed as fn(*args, **kwargs) and returns
|
Schedules the callable to be executed as fn(*args, **kwargs) and returns
|
||||||
@ -556,21 +556,7 @@ class Executor(object):
|
|||||||
Returns:
|
Returns:
|
||||||
A Future representing the given call.
|
A Future representing the given call.
|
||||||
"""
|
"""
|
||||||
if len(args) >= 2:
|
|
||||||
pass
|
|
||||||
elif not args:
|
|
||||||
raise TypeError("descriptor 'submit' of 'Executor' object "
|
|
||||||
"needs an argument")
|
|
||||||
elif 'fn' in kwargs:
|
|
||||||
import warnings
|
|
||||||
warnings.warn("Passing 'fn' as keyword argument is deprecated",
|
|
||||||
DeprecationWarning, stacklevel=2)
|
|
||||||
else:
|
|
||||||
raise TypeError('submit expected at least 1 positional argument, '
|
|
||||||
'got %d' % (len(args)-1))
|
|
||||||
|
|
||||||
raise NotImplementedError()
|
raise NotImplementedError()
|
||||||
submit.__text_signature__ = '($self, fn, /, *args, **kwargs)'
|
|
||||||
|
|
||||||
def map(self, fn, *iterables, timeout=None, chunksize=1):
|
def map(self, fn, *iterables, timeout=None, chunksize=1):
|
||||||
"""Returns an iterator equivalent to map(fn, iter).
|
"""Returns an iterator equivalent to map(fn, iter).
|
||||||
|
@ -608,22 +608,7 @@ class ProcessPoolExecutor(_base.Executor):
|
|||||||
p.start()
|
p.start()
|
||||||
self._processes[p.pid] = p
|
self._processes[p.pid] = p
|
||||||
|
|
||||||
def submit(*args, **kwargs):
|
def submit(self, fn, /, *args, **kwargs):
|
||||||
if len(args) >= 2:
|
|
||||||
self, fn, *args = args
|
|
||||||
elif not args:
|
|
||||||
raise TypeError("descriptor 'submit' of 'ProcessPoolExecutor' object "
|
|
||||||
"needs an argument")
|
|
||||||
elif 'fn' in kwargs:
|
|
||||||
fn = kwargs.pop('fn')
|
|
||||||
self, *args = args
|
|
||||||
import warnings
|
|
||||||
warnings.warn("Passing 'fn' as keyword argument is deprecated",
|
|
||||||
DeprecationWarning, stacklevel=2)
|
|
||||||
else:
|
|
||||||
raise TypeError('submit expected at least 1 positional argument, '
|
|
||||||
'got %d' % (len(args)-1))
|
|
||||||
|
|
||||||
with self._shutdown_lock:
|
with self._shutdown_lock:
|
||||||
if self._broken:
|
if self._broken:
|
||||||
raise BrokenProcessPool(self._broken)
|
raise BrokenProcessPool(self._broken)
|
||||||
@ -644,7 +629,6 @@ class ProcessPoolExecutor(_base.Executor):
|
|||||||
|
|
||||||
self._start_queue_management_thread()
|
self._start_queue_management_thread()
|
||||||
return f
|
return f
|
||||||
submit.__text_signature__ = _base.Executor.submit.__text_signature__
|
|
||||||
submit.__doc__ = _base.Executor.submit.__doc__
|
submit.__doc__ = _base.Executor.submit.__doc__
|
||||||
|
|
||||||
def map(self, fn, *iterables, timeout=None, chunksize=1):
|
def map(self, fn, *iterables, timeout=None, chunksize=1):
|
||||||
|
@ -155,22 +155,7 @@ class ThreadPoolExecutor(_base.Executor):
|
|||||||
self._initializer = initializer
|
self._initializer = initializer
|
||||||
self._initargs = initargs
|
self._initargs = initargs
|
||||||
|
|
||||||
def submit(*args, **kwargs):
|
def submit(self, fn, /, *args, **kwargs):
|
||||||
if len(args) >= 2:
|
|
||||||
self, fn, *args = args
|
|
||||||
elif not args:
|
|
||||||
raise TypeError("descriptor 'submit' of 'ThreadPoolExecutor' object "
|
|
||||||
"needs an argument")
|
|
||||||
elif 'fn' in kwargs:
|
|
||||||
fn = kwargs.pop('fn')
|
|
||||||
self, *args = args
|
|
||||||
import warnings
|
|
||||||
warnings.warn("Passing 'fn' as keyword argument is deprecated",
|
|
||||||
DeprecationWarning, stacklevel=2)
|
|
||||||
else:
|
|
||||||
raise TypeError('submit expected at least 1 positional argument, '
|
|
||||||
'got %d' % (len(args)-1))
|
|
||||||
|
|
||||||
with self._shutdown_lock:
|
with self._shutdown_lock:
|
||||||
if self._broken:
|
if self._broken:
|
||||||
raise BrokenThreadPool(self._broken)
|
raise BrokenThreadPool(self._broken)
|
||||||
@ -187,7 +172,6 @@ class ThreadPoolExecutor(_base.Executor):
|
|||||||
self._work_queue.put(w)
|
self._work_queue.put(w)
|
||||||
self._adjust_thread_count()
|
self._adjust_thread_count()
|
||||||
return f
|
return f
|
||||||
submit.__text_signature__ = _base.Executor.submit.__text_signature__
|
|
||||||
submit.__doc__ = _base.Executor.submit.__doc__
|
submit.__doc__ = _base.Executor.submit.__doc__
|
||||||
|
|
||||||
def _adjust_thread_count(self):
|
def _adjust_thread_count(self):
|
||||||
|
@ -426,26 +426,11 @@ class _BaseExitStack:
|
|||||||
self._push_cm_exit(cm, _exit)
|
self._push_cm_exit(cm, _exit)
|
||||||
return result
|
return result
|
||||||
|
|
||||||
def callback(*args, **kwds):
|
def callback(self, callback, /, *args, **kwds):
|
||||||
"""Registers an arbitrary callback and arguments.
|
"""Registers an arbitrary callback and arguments.
|
||||||
|
|
||||||
Cannot suppress exceptions.
|
Cannot suppress exceptions.
|
||||||
"""
|
"""
|
||||||
if len(args) >= 2:
|
|
||||||
self, callback, *args = args
|
|
||||||
elif not args:
|
|
||||||
raise TypeError("descriptor 'callback' of '_BaseExitStack' object "
|
|
||||||
"needs an argument")
|
|
||||||
elif 'callback' in kwds:
|
|
||||||
callback = kwds.pop('callback')
|
|
||||||
self, *args = args
|
|
||||||
import warnings
|
|
||||||
warnings.warn("Passing 'callback' as keyword argument is deprecated",
|
|
||||||
DeprecationWarning, stacklevel=2)
|
|
||||||
else:
|
|
||||||
raise TypeError('callback expected at least 1 positional argument, '
|
|
||||||
'got %d' % (len(args)-1))
|
|
||||||
|
|
||||||
_exit_wrapper = self._create_cb_wrapper(callback, *args, **kwds)
|
_exit_wrapper = self._create_cb_wrapper(callback, *args, **kwds)
|
||||||
|
|
||||||
# We changed the signature, so using @wraps is not appropriate, but
|
# We changed the signature, so using @wraps is not appropriate, but
|
||||||
@ -453,7 +438,6 @@ class _BaseExitStack:
|
|||||||
_exit_wrapper.__wrapped__ = callback
|
_exit_wrapper.__wrapped__ = callback
|
||||||
self._push_exit_callback(_exit_wrapper)
|
self._push_exit_callback(_exit_wrapper)
|
||||||
return callback # Allow use as a decorator
|
return callback # Allow use as a decorator
|
||||||
callback.__text_signature__ = '($self, callback, /, *args, **kwds)'
|
|
||||||
|
|
||||||
def _push_cm_exit(self, cm, cm_exit):
|
def _push_cm_exit(self, cm, cm_exit):
|
||||||
"""Helper to correctly register callbacks to __exit__ methods."""
|
"""Helper to correctly register callbacks to __exit__ methods."""
|
||||||
@ -587,26 +571,11 @@ class AsyncExitStack(_BaseExitStack, AbstractAsyncContextManager):
|
|||||||
self._push_async_cm_exit(exit, exit_method)
|
self._push_async_cm_exit(exit, exit_method)
|
||||||
return exit # Allow use as a decorator
|
return exit # Allow use as a decorator
|
||||||
|
|
||||||
def push_async_callback(*args, **kwds):
|
def push_async_callback(self, callback, /, *args, **kwds):
|
||||||
"""Registers an arbitrary coroutine function and arguments.
|
"""Registers an arbitrary coroutine function and arguments.
|
||||||
|
|
||||||
Cannot suppress exceptions.
|
Cannot suppress exceptions.
|
||||||
"""
|
"""
|
||||||
if len(args) >= 2:
|
|
||||||
self, callback, *args = args
|
|
||||||
elif not args:
|
|
||||||
raise TypeError("descriptor 'push_async_callback' of "
|
|
||||||
"'AsyncExitStack' object needs an argument")
|
|
||||||
elif 'callback' in kwds:
|
|
||||||
callback = kwds.pop('callback')
|
|
||||||
self, *args = args
|
|
||||||
import warnings
|
|
||||||
warnings.warn("Passing 'callback' as keyword argument is deprecated",
|
|
||||||
DeprecationWarning, stacklevel=2)
|
|
||||||
else:
|
|
||||||
raise TypeError('push_async_callback expected at least 1 '
|
|
||||||
'positional argument, got %d' % (len(args)-1))
|
|
||||||
|
|
||||||
_exit_wrapper = self._create_async_cb_wrapper(callback, *args, **kwds)
|
_exit_wrapper = self._create_async_cb_wrapper(callback, *args, **kwds)
|
||||||
|
|
||||||
# We changed the signature, so using @wraps is not appropriate, but
|
# We changed the signature, so using @wraps is not appropriate, but
|
||||||
@ -614,7 +583,6 @@ class AsyncExitStack(_BaseExitStack, AbstractAsyncContextManager):
|
|||||||
_exit_wrapper.__wrapped__ = callback
|
_exit_wrapper.__wrapped__ = callback
|
||||||
self._push_exit_callback(_exit_wrapper, False)
|
self._push_exit_callback(_exit_wrapper, False)
|
||||||
return callback # Allow use as a decorator
|
return callback # Allow use as a decorator
|
||||||
push_async_callback.__text_signature__ = '($self, callback, /, *args, **kwds)'
|
|
||||||
|
|
||||||
async def aclose(self):
|
async def aclose(self):
|
||||||
"""Immediately unwind the context stack."""
|
"""Immediately unwind the context stack."""
|
||||||
|
@ -60,7 +60,7 @@ except NameError:
|
|||||||
# raises an exception, wrapper() will restore the terminal to a sane state so
|
# raises an exception, wrapper() will restore the terminal to a sane state so
|
||||||
# you can read the resulting traceback.
|
# you can read the resulting traceback.
|
||||||
|
|
||||||
def wrapper(*args, **kwds):
|
def wrapper(func, /, *args, **kwds):
|
||||||
"""Wrapper function that initializes curses and calls another function,
|
"""Wrapper function that initializes curses and calls another function,
|
||||||
restoring normal keyboard/screen behavior on error.
|
restoring normal keyboard/screen behavior on error.
|
||||||
The callable object 'func' is then passed the main window 'stdscr'
|
The callable object 'func' is then passed the main window 'stdscr'
|
||||||
@ -68,17 +68,6 @@ def wrapper(*args, **kwds):
|
|||||||
wrapper().
|
wrapper().
|
||||||
"""
|
"""
|
||||||
|
|
||||||
if args:
|
|
||||||
func, *args = args
|
|
||||||
elif 'func' in kwds:
|
|
||||||
func = kwds.pop('func')
|
|
||||||
import warnings
|
|
||||||
warnings.warn("Passing 'func' as keyword argument is deprecated",
|
|
||||||
DeprecationWarning, stacklevel=2)
|
|
||||||
else:
|
|
||||||
raise TypeError('wrapper expected at least 1 positional argument, '
|
|
||||||
'got %d' % len(args))
|
|
||||||
|
|
||||||
try:
|
try:
|
||||||
# Initialize curses
|
# Initialize curses
|
||||||
stdscr = initscr()
|
stdscr = initscr()
|
||||||
@ -110,4 +99,3 @@ def wrapper(*args, **kwds):
|
|||||||
echo()
|
echo()
|
||||||
nocbreak()
|
nocbreak()
|
||||||
endwin()
|
endwin()
|
||||||
wrapper.__text_signature__ = '(func, /, *args, **kwds)'
|
|
||||||
|
@ -345,23 +345,7 @@ class partialmethod(object):
|
|||||||
callables as instance methods.
|
callables as instance methods.
|
||||||
"""
|
"""
|
||||||
|
|
||||||
def __init__(*args, **keywords):
|
def __init__(self, func, /, *args, **keywords):
|
||||||
if len(args) >= 2:
|
|
||||||
self, func, *args = args
|
|
||||||
elif not args:
|
|
||||||
raise TypeError("descriptor '__init__' of partialmethod "
|
|
||||||
"needs an argument")
|
|
||||||
elif 'func' in keywords:
|
|
||||||
func = keywords.pop('func')
|
|
||||||
self, *args = args
|
|
||||||
import warnings
|
|
||||||
warnings.warn("Passing 'func' as keyword argument is deprecated",
|
|
||||||
DeprecationWarning, stacklevel=2)
|
|
||||||
else:
|
|
||||||
raise TypeError("type 'partialmethod' takes at least one argument, "
|
|
||||||
"got %d" % (len(args)-1))
|
|
||||||
args = tuple(args)
|
|
||||||
|
|
||||||
if not callable(func) and not hasattr(func, "__get__"):
|
if not callable(func) and not hasattr(func, "__get__"):
|
||||||
raise TypeError("{!r} is not callable or a descriptor"
|
raise TypeError("{!r} is not callable or a descriptor"
|
||||||
.format(func))
|
.format(func))
|
||||||
@ -379,7 +363,6 @@ class partialmethod(object):
|
|||||||
self.func = func
|
self.func = func
|
||||||
self.args = args
|
self.args = args
|
||||||
self.keywords = keywords
|
self.keywords = keywords
|
||||||
__init__.__text_signature__ = '($self, func, /, *args, **keywords)'
|
|
||||||
|
|
||||||
def __repr__(self):
|
def __repr__(self):
|
||||||
args = ", ".join(map(repr, self.args))
|
args = ", ".join(map(repr, self.args))
|
||||||
|
@ -360,36 +360,10 @@ class Server(object):
|
|||||||
finally:
|
finally:
|
||||||
self.stop_event.set()
|
self.stop_event.set()
|
||||||
|
|
||||||
def create(*args, **kwds):
|
def create(self, c, typeid, /, *args, **kwds):
|
||||||
'''
|
'''
|
||||||
Create a new shared object and return its id
|
Create a new shared object and return its id
|
||||||
'''
|
'''
|
||||||
if len(args) >= 3:
|
|
||||||
self, c, typeid, *args = args
|
|
||||||
elif not args:
|
|
||||||
raise TypeError("descriptor 'create' of 'Server' object "
|
|
||||||
"needs an argument")
|
|
||||||
else:
|
|
||||||
if 'typeid' not in kwds:
|
|
||||||
raise TypeError('create expected at least 2 positional '
|
|
||||||
'arguments, got %d' % (len(args)-1))
|
|
||||||
typeid = kwds.pop('typeid')
|
|
||||||
if len(args) >= 2:
|
|
||||||
self, c, *args = args
|
|
||||||
import warnings
|
|
||||||
warnings.warn("Passing 'typeid' as keyword argument is deprecated",
|
|
||||||
DeprecationWarning, stacklevel=2)
|
|
||||||
else:
|
|
||||||
if 'c' not in kwds:
|
|
||||||
raise TypeError('create expected at least 2 positional '
|
|
||||||
'arguments, got %d' % (len(args)-1))
|
|
||||||
c = kwds.pop('c')
|
|
||||||
self, *args = args
|
|
||||||
import warnings
|
|
||||||
warnings.warn("Passing 'c' as keyword argument is deprecated",
|
|
||||||
DeprecationWarning, stacklevel=2)
|
|
||||||
args = tuple(args)
|
|
||||||
|
|
||||||
with self.mutex:
|
with self.mutex:
|
||||||
callable, exposed, method_to_typeid, proxytype = \
|
callable, exposed, method_to_typeid, proxytype = \
|
||||||
self.registry[typeid]
|
self.registry[typeid]
|
||||||
@ -421,7 +395,6 @@ class Server(object):
|
|||||||
|
|
||||||
self.incref(c, ident)
|
self.incref(c, ident)
|
||||||
return ident, tuple(exposed)
|
return ident, tuple(exposed)
|
||||||
create.__text_signature__ = '($self, c, typeid, /, *args, **kwds)'
|
|
||||||
|
|
||||||
def get_methods(self, c, token):
|
def get_methods(self, c, token):
|
||||||
'''
|
'''
|
||||||
@ -1293,26 +1266,15 @@ if HAS_SHMEM:
|
|||||||
_SharedMemoryTracker(f"shmm_{self.address}_{getpid()}")
|
_SharedMemoryTracker(f"shmm_{self.address}_{getpid()}")
|
||||||
util.debug(f"SharedMemoryServer started by pid {getpid()}")
|
util.debug(f"SharedMemoryServer started by pid {getpid()}")
|
||||||
|
|
||||||
def create(*args, **kwargs):
|
def create(self, c, typeid, /, *args, **kwargs):
|
||||||
"""Create a new distributed-shared object (not backed by a shared
|
"""Create a new distributed-shared object (not backed by a shared
|
||||||
memory block) and return its id to be used in a Proxy Object."""
|
memory block) and return its id to be used in a Proxy Object."""
|
||||||
# Unless set up as a shared proxy, don't make shared_memory_context
|
# Unless set up as a shared proxy, don't make shared_memory_context
|
||||||
# a standard part of kwargs. This makes things easier for supplying
|
# a standard part of kwargs. This makes things easier for supplying
|
||||||
# simple functions.
|
# simple functions.
|
||||||
if len(args) >= 3:
|
|
||||||
typeod = args[2]
|
|
||||||
elif 'typeid' in kwargs:
|
|
||||||
typeid = kwargs['typeid']
|
|
||||||
elif not args:
|
|
||||||
raise TypeError("descriptor 'create' of 'SharedMemoryServer' "
|
|
||||||
"object needs an argument")
|
|
||||||
else:
|
|
||||||
raise TypeError('create expected at least 2 positional '
|
|
||||||
'arguments, got %d' % (len(args)-1))
|
|
||||||
if hasattr(self.registry[typeid][-1], "_shared_memory_proxy"):
|
if hasattr(self.registry[typeid][-1], "_shared_memory_proxy"):
|
||||||
kwargs['shared_memory_context'] = self.shared_memory_context
|
kwargs['shared_memory_context'] = self.shared_memory_context
|
||||||
return Server.create(*args, **kwargs)
|
return Server.create(self, c, typeid, *args, **kwargs)
|
||||||
create.__text_signature__ = '($self, c, typeid, /, *args, **kwargs)'
|
|
||||||
|
|
||||||
def shutdown(self, c):
|
def shutdown(self, c):
|
||||||
"Call unlink() on all tracked shared memory, terminate the Server."
|
"Call unlink() on all tracked shared memory, terminate the Server."
|
||||||
|
@ -425,29 +425,13 @@ class Profile:
|
|||||||
return self
|
return self
|
||||||
|
|
||||||
# This method is more useful to profile a single function call.
|
# This method is more useful to profile a single function call.
|
||||||
def runcall(*args, **kw):
|
def runcall(self, func, /, *args, **kw):
|
||||||
if len(args) >= 2:
|
|
||||||
self, func, *args = args
|
|
||||||
elif not args:
|
|
||||||
raise TypeError("descriptor 'runcall' of 'Profile' object "
|
|
||||||
"needs an argument")
|
|
||||||
elif 'func' in kw:
|
|
||||||
func = kw.pop('func')
|
|
||||||
self, *args = args
|
|
||||||
import warnings
|
|
||||||
warnings.warn("Passing 'func' as keyword argument is deprecated",
|
|
||||||
DeprecationWarning, stacklevel=2)
|
|
||||||
else:
|
|
||||||
raise TypeError('runcall expected at least 1 positional argument, '
|
|
||||||
'got %d' % (len(args)-1))
|
|
||||||
|
|
||||||
self.set_cmd(repr(func))
|
self.set_cmd(repr(func))
|
||||||
sys.setprofile(self.dispatcher)
|
sys.setprofile(self.dispatcher)
|
||||||
try:
|
try:
|
||||||
return func(*args, **kw)
|
return func(*args, **kw)
|
||||||
finally:
|
finally:
|
||||||
sys.setprofile(None)
|
sys.setprofile(None)
|
||||||
runcall.__text_signature__ = '($self, func, /, *args, **kw)'
|
|
||||||
|
|
||||||
|
|
||||||
#******************************************************************
|
#******************************************************************
|
||||||
|
@ -668,9 +668,8 @@ class ExecutorTest:
|
|||||||
self.assertEqual(16, future.result())
|
self.assertEqual(16, future.result())
|
||||||
future = self.executor.submit(capture, 1, self=2, fn=3)
|
future = self.executor.submit(capture, 1, self=2, fn=3)
|
||||||
self.assertEqual(future.result(), ((1,), {'self': 2, 'fn': 3}))
|
self.assertEqual(future.result(), ((1,), {'self': 2, 'fn': 3}))
|
||||||
with self.assertWarns(DeprecationWarning):
|
with self.assertRaises(TypeError):
|
||||||
future = self.executor.submit(fn=capture, arg=1)
|
self.executor.submit(fn=capture, arg=1)
|
||||||
self.assertEqual(future.result(), ((), {'arg': 1}))
|
|
||||||
with self.assertRaises(TypeError):
|
with self.assertRaises(TypeError):
|
||||||
self.executor.submit(arg=1)
|
self.executor.submit(arg=1)
|
||||||
|
|
||||||
|
@ -603,9 +603,9 @@ class TestBaseExitStack:
|
|||||||
stack.callback(arg=1)
|
stack.callback(arg=1)
|
||||||
with self.assertRaises(TypeError):
|
with self.assertRaises(TypeError):
|
||||||
self.exit_stack.callback(arg=2)
|
self.exit_stack.callback(arg=2)
|
||||||
with self.assertWarns(DeprecationWarning):
|
with self.assertRaises(TypeError):
|
||||||
stack.callback(callback=_exit, arg=3)
|
stack.callback(callback=_exit, arg=3)
|
||||||
self.assertEqual(result, [((), {'arg': 3})])
|
self.assertEqual(result, [])
|
||||||
|
|
||||||
def test_push(self):
|
def test_push(self):
|
||||||
exc_raised = ZeroDivisionError
|
exc_raised = ZeroDivisionError
|
||||||
|
@ -358,9 +358,9 @@ class TestAsyncExitStack(TestBaseExitStack, unittest.TestCase):
|
|||||||
stack.push_async_callback(arg=1)
|
stack.push_async_callback(arg=1)
|
||||||
with self.assertRaises(TypeError):
|
with self.assertRaises(TypeError):
|
||||||
self.exit_stack.push_async_callback(arg=2)
|
self.exit_stack.push_async_callback(arg=2)
|
||||||
with self.assertWarns(DeprecationWarning):
|
with self.assertRaises(TypeError):
|
||||||
stack.push_async_callback(callback=_exit, arg=3)
|
stack.push_async_callback(callback=_exit, arg=3)
|
||||||
self.assertEqual(result, [((), {'arg': 3})])
|
self.assertEqual(result, [])
|
||||||
|
|
||||||
@_async_test
|
@_async_test
|
||||||
async def test_async_push(self):
|
async def test_async_push(self):
|
||||||
|
@ -556,11 +556,9 @@ class TestPartialMethod(unittest.TestCase):
|
|||||||
with self.assertRaises(TypeError):
|
with self.assertRaises(TypeError):
|
||||||
class B:
|
class B:
|
||||||
method = functools.partialmethod()
|
method = functools.partialmethod()
|
||||||
with self.assertWarns(DeprecationWarning):
|
with self.assertRaises(TypeError):
|
||||||
class B:
|
class B:
|
||||||
method = functools.partialmethod(func=capture, a=1)
|
method = functools.partialmethod(func=capture, a=1)
|
||||||
b = B()
|
|
||||||
self.assertEqual(b.method(2, x=3), ((b, 2), {'a': 1, 'x': 3}))
|
|
||||||
|
|
||||||
def test_repr(self):
|
def test_repr(self):
|
||||||
self.assertEqual(repr(vars(self.A)['both']),
|
self.assertEqual(repr(vars(self.A)['both']),
|
||||||
|
@ -276,9 +276,8 @@ class TestFuncs(unittest.TestCase):
|
|||||||
def test_arg_errors(self):
|
def test_arg_errors(self):
|
||||||
res = self.tracer.runfunc(traced_capturer, 1, 2, self=3, func=4)
|
res = self.tracer.runfunc(traced_capturer, 1, 2, self=3, func=4)
|
||||||
self.assertEqual(res, ((1, 2), {'self': 3, 'func': 4}))
|
self.assertEqual(res, ((1, 2), {'self': 3, 'func': 4}))
|
||||||
with self.assertWarns(DeprecationWarning):
|
with self.assertRaises(TypeError):
|
||||||
res = self.tracer.runfunc(func=traced_capturer, arg=1)
|
self.tracer.runfunc(func=traced_capturer, arg=1)
|
||||||
self.assertEqual(res, ((), {'arg': 1}))
|
|
||||||
with self.assertRaises(TypeError):
|
with self.assertRaises(TypeError):
|
||||||
self.tracer.runfunc()
|
self.tracer.runfunc()
|
||||||
|
|
||||||
|
@ -30,8 +30,8 @@ class UserDictTest(mapping_tests.TestHashMappingProtocol):
|
|||||||
self.assertEqual(collections.UserDict(one=1, two=2), d2)
|
self.assertEqual(collections.UserDict(one=1, two=2), d2)
|
||||||
# item sequence constructor
|
# item sequence constructor
|
||||||
self.assertEqual(collections.UserDict([('one',1), ('two',2)]), d2)
|
self.assertEqual(collections.UserDict([('one',1), ('two',2)]), d2)
|
||||||
with self.assertWarnsRegex(DeprecationWarning, "'dict'"):
|
self.assertEqual(collections.UserDict(dict=[('one',1), ('two',2)]),
|
||||||
self.assertEqual(collections.UserDict(dict=[('one',1), ('two',2)]), d2)
|
{'dict': [('one', 1), ('two', 2)]})
|
||||||
# both together
|
# both together
|
||||||
self.assertEqual(collections.UserDict([('one',1), ('two',2)], two=3, three=5), d3)
|
self.assertEqual(collections.UserDict([('one',1), ('two',2)], two=3, three=5), d3)
|
||||||
|
|
||||||
@ -149,9 +149,8 @@ class UserDictTest(mapping_tests.TestHashMappingProtocol):
|
|||||||
[('dict', 42)])
|
[('dict', 42)])
|
||||||
self.assertEqual(list(collections.UserDict({}, dict=None).items()),
|
self.assertEqual(list(collections.UserDict({}, dict=None).items()),
|
||||||
[('dict', None)])
|
[('dict', None)])
|
||||||
with self.assertWarnsRegex(DeprecationWarning, "'dict'"):
|
self.assertEqual(list(collections.UserDict(dict={'a': 42}).items()),
|
||||||
self.assertEqual(list(collections.UserDict(dict={'a': 42}).items()),
|
[('dict', {'a': 42})])
|
||||||
[('a', 42)])
|
|
||||||
self.assertRaises(TypeError, collections.UserDict, 42)
|
self.assertRaises(TypeError, collections.UserDict, 42)
|
||||||
self.assertRaises(TypeError, collections.UserDict, (), ())
|
self.assertRaises(TypeError, collections.UserDict, (), ())
|
||||||
self.assertRaises(TypeError, collections.UserDict.__init__)
|
self.assertRaises(TypeError, collections.UserDict.__init__)
|
||||||
|
@ -1866,20 +1866,10 @@ class FinalizeTestCase(unittest.TestCase):
|
|||||||
f()
|
f()
|
||||||
self.assertEqual(res, [((1, 2), {'func': 3, 'obj': 4})])
|
self.assertEqual(res, [((1, 2), {'func': 3, 'obj': 4})])
|
||||||
|
|
||||||
res = []
|
with self.assertRaises(TypeError):
|
||||||
with self.assertWarns(DeprecationWarning):
|
weakref.finalize(a, func=fin, arg=1)
|
||||||
f = weakref.finalize(a, func=fin, arg=1)
|
with self.assertRaises(TypeError):
|
||||||
self.assertEqual(f.peek(), (a, fin, (), {'arg': 1}))
|
weakref.finalize(obj=a, func=fin, arg=1)
|
||||||
f()
|
|
||||||
self.assertEqual(res, [((), {'arg': 1})])
|
|
||||||
|
|
||||||
res = []
|
|
||||||
with self.assertWarns(DeprecationWarning):
|
|
||||||
f = weakref.finalize(obj=a, func=fin, arg=1)
|
|
||||||
self.assertEqual(f.peek(), (a, fin, (), {'arg': 1}))
|
|
||||||
f()
|
|
||||||
self.assertEqual(res, [((), {'arg': 1})])
|
|
||||||
|
|
||||||
self.assertRaises(TypeError, weakref.finalize, a)
|
self.assertRaises(TypeError, weakref.finalize, a)
|
||||||
self.assertRaises(TypeError, weakref.finalize)
|
self.assertRaises(TypeError, weakref.finalize)
|
||||||
|
|
||||||
|
18
Lib/trace.py
18
Lib/trace.py
@ -451,22 +451,7 @@ class Trace:
|
|||||||
sys.settrace(None)
|
sys.settrace(None)
|
||||||
threading.settrace(None)
|
threading.settrace(None)
|
||||||
|
|
||||||
def runfunc(*args, **kw):
|
def runfunc(self, func, /, *args, **kw):
|
||||||
if len(args) >= 2:
|
|
||||||
self, func, *args = args
|
|
||||||
elif not args:
|
|
||||||
raise TypeError("descriptor 'runfunc' of 'Trace' object "
|
|
||||||
"needs an argument")
|
|
||||||
elif 'func' in kw:
|
|
||||||
func = kw.pop('func')
|
|
||||||
self, *args = args
|
|
||||||
import warnings
|
|
||||||
warnings.warn("Passing 'func' as keyword argument is deprecated",
|
|
||||||
DeprecationWarning, stacklevel=2)
|
|
||||||
else:
|
|
||||||
raise TypeError('runfunc expected at least 1 positional argument, '
|
|
||||||
'got %d' % (len(args)-1))
|
|
||||||
|
|
||||||
result = None
|
result = None
|
||||||
if not self.donothing:
|
if not self.donothing:
|
||||||
sys.settrace(self.globaltrace)
|
sys.settrace(self.globaltrace)
|
||||||
@ -476,7 +461,6 @@ class Trace:
|
|||||||
if not self.donothing:
|
if not self.donothing:
|
||||||
sys.settrace(None)
|
sys.settrace(None)
|
||||||
return result
|
return result
|
||||||
runfunc.__text_signature__ = '($self, func, /, *args, **kw)'
|
|
||||||
|
|
||||||
def file_module_function_of(self, frame):
|
def file_module_function_of(self, frame):
|
||||||
code = frame.f_code
|
code = frame.f_code
|
||||||
|
@ -463,30 +463,13 @@ class TestCase(object):
|
|||||||
"""
|
"""
|
||||||
self._type_equality_funcs[typeobj] = function
|
self._type_equality_funcs[typeobj] = function
|
||||||
|
|
||||||
def addCleanup(*args, **kwargs):
|
def addCleanup(self, function, /, *args, **kwargs):
|
||||||
"""Add a function, with arguments, to be called when the test is
|
"""Add a function, with arguments, to be called when the test is
|
||||||
completed. Functions added are called on a LIFO basis and are
|
completed. Functions added are called on a LIFO basis and are
|
||||||
called after tearDown on test failure or success.
|
called after tearDown on test failure or success.
|
||||||
|
|
||||||
Cleanup items are called even if setUp fails (unlike tearDown)."""
|
Cleanup items are called even if setUp fails (unlike tearDown)."""
|
||||||
if len(args) >= 2:
|
|
||||||
self, function, *args = args
|
|
||||||
elif not args:
|
|
||||||
raise TypeError("descriptor 'addCleanup' of 'TestCase' object "
|
|
||||||
"needs an argument")
|
|
||||||
elif 'function' in kwargs:
|
|
||||||
function = kwargs.pop('function')
|
|
||||||
self, *args = args
|
|
||||||
import warnings
|
|
||||||
warnings.warn("Passing 'function' as keyword argument is deprecated",
|
|
||||||
DeprecationWarning, stacklevel=2)
|
|
||||||
else:
|
|
||||||
raise TypeError('addCleanup expected at least 1 positional '
|
|
||||||
'argument, got %d' % (len(args)-1))
|
|
||||||
args = tuple(args)
|
|
||||||
|
|
||||||
self._cleanups.append((function, args, kwargs))
|
self._cleanups.append((function, args, kwargs))
|
||||||
addCleanup.__text_signature__ = '($self, function, /, *args, **kwargs)'
|
|
||||||
|
|
||||||
@classmethod
|
@classmethod
|
||||||
def addClassCleanup(cls, function, /, *args, **kwargs):
|
def addClassCleanup(cls, function, /, *args, **kwargs):
|
||||||
|
@ -592,7 +592,7 @@ class TestModuleCleanUp(unittest.TestCase):
|
|||||||
class TestableTest(unittest.TestCase):
|
class TestableTest(unittest.TestCase):
|
||||||
def setUp(self2):
|
def setUp(self2):
|
||||||
self2.addCleanup(cleanup, 1, 2, function=3, self=4)
|
self2.addCleanup(cleanup, 1, 2, function=3, self=4)
|
||||||
with self.assertWarns(DeprecationWarning):
|
with self.assertRaises(TypeError):
|
||||||
self2.addCleanup(function=cleanup, arg='hello')
|
self2.addCleanup(function=cleanup, arg='hello')
|
||||||
def testNothing(self):
|
def testNothing(self):
|
||||||
pass
|
pass
|
||||||
@ -603,8 +603,7 @@ class TestModuleCleanUp(unittest.TestCase):
|
|||||||
unittest.TestCase.addCleanup(self=TestableTest(), function=cleanup)
|
unittest.TestCase.addCleanup(self=TestableTest(), function=cleanup)
|
||||||
runTests(TestableTest)
|
runTests(TestableTest)
|
||||||
self.assertEqual(cleanups,
|
self.assertEqual(cleanups,
|
||||||
[((), {'arg': 'hello'}),
|
[((1, 2), {'function': 3, 'self': 4})])
|
||||||
((1, 2), {'function': 3, 'self': 4})])
|
|
||||||
|
|
||||||
def test_with_errors_in_addClassCleanup(self):
|
def test_with_errors_in_addClassCleanup(self):
|
||||||
ordering = []
|
ordering = []
|
||||||
|
@ -514,33 +514,7 @@ class finalize:
|
|||||||
class _Info:
|
class _Info:
|
||||||
__slots__ = ("weakref", "func", "args", "kwargs", "atexit", "index")
|
__slots__ = ("weakref", "func", "args", "kwargs", "atexit", "index")
|
||||||
|
|
||||||
def __init__(*args, **kwargs):
|
def __init__(self, obj, func, /, *args, **kwargs):
|
||||||
if len(args) >= 3:
|
|
||||||
self, obj, func, *args = args
|
|
||||||
elif not args:
|
|
||||||
raise TypeError("descriptor '__init__' of 'finalize' object "
|
|
||||||
"needs an argument")
|
|
||||||
else:
|
|
||||||
if 'func' not in kwargs:
|
|
||||||
raise TypeError('finalize expected at least 2 positional '
|
|
||||||
'arguments, got %d' % (len(args)-1))
|
|
||||||
func = kwargs.pop('func')
|
|
||||||
if len(args) >= 2:
|
|
||||||
self, obj, *args = args
|
|
||||||
import warnings
|
|
||||||
warnings.warn("Passing 'func' as keyword argument is deprecated",
|
|
||||||
DeprecationWarning, stacklevel=2)
|
|
||||||
else:
|
|
||||||
if 'obj' not in kwargs:
|
|
||||||
raise TypeError('finalize expected at least 2 positional '
|
|
||||||
'arguments, got %d' % (len(args)-1))
|
|
||||||
obj = kwargs.pop('obj')
|
|
||||||
self, *args = args
|
|
||||||
import warnings
|
|
||||||
warnings.warn("Passing 'obj' as keyword argument is deprecated",
|
|
||||||
DeprecationWarning, stacklevel=2)
|
|
||||||
args = tuple(args)
|
|
||||||
|
|
||||||
if not self._registered_with_atexit:
|
if not self._registered_with_atexit:
|
||||||
# We may register the exit function more than once because
|
# We may register the exit function more than once because
|
||||||
# of a thread race, but that is harmless
|
# of a thread race, but that is harmless
|
||||||
@ -556,7 +530,6 @@ class finalize:
|
|||||||
info.index = next(self._index_iter)
|
info.index = next(self._index_iter)
|
||||||
self._registry[self] = info
|
self._registry[self] = info
|
||||||
finalize._dirty = True
|
finalize._dirty = True
|
||||||
__init__.__text_signature__ = '($self, obj, func, /, *args, **kwargs)'
|
|
||||||
|
|
||||||
def __call__(self, _=None):
|
def __call__(self, _=None):
|
||||||
"""If alive then mark as dead and return func(*args, **kwargs);
|
"""If alive then mark as dead and return func(*args, **kwargs);
|
||||||
|
Loading…
Reference in New Issue
Block a user