Upgrading anyio 2 to 3
Unknown2.2.0 → 3.7.1
UnknownUpgrade verdict
DepDelta hasn't looked for this range's notes yet, so breaking changes can't be ruled out.
In plain terms
- DepDelta hasn't finished looking for the notes in this range, so it can't rule out breaking changes yet.
- Their commits are listed with this comparison.
Must act Unknown for releases without notes
Releases without notes may still need changes. Check their commits before upgrading.
Python requirement changed in 3.7.0rc1: >=3.6.2 → >=3.7.
API changes
Generated by DepDelta from published Python source. Not mixed with prose notes.
- added:
export BrokenWorkerProcess - added:
export CancelScope - added:
export CapacityLimiter - added:
export CapacityLimiterStatistics - added:
export Condition - added:
export ConditionStatistics - added:
export Event - added:
export EventStatistics - added:
export Lock - added:
export LockStatistics - added:
export Path - added:
export Semaphore - added:
export SemaphoreStatistics - added:
export TASK_STATUS_IGNORED - added:
export run_sync_from_thread - added:
export sleep_forever - added:
export sleep_until - added:
export wrap_file
- added:
export IPAddressType - added:
export IPSockAddrType - added:
export TaskStatus - added:
export UDPPacketType - added:
export UNIXSocketStream
- removed:
async method AsyncResource.aclose() -> None - removed:
class AsyncResource
- removed:
async method SocketListener.accept() -> SocketStream[T_SockAddr] - removed:
async method SocketListener.serve(handler: Callable[[T_Stream], Any], task_group: Optional[TaskGroup]=…) -> None - removed:
async method UDPSocket.sendto(data: bytes, host: str, port: int) -> None - removed:
class ConnectedUDPSocket(UnreliableObjectStream[bytes], _SocketProvider[IPSockAddrType]) - removed:
class SocketAttribute(TypedAttributeSet) - removed:
class SocketListener(Generic[T_SockAddr], Listener[SocketStream[T_SockAddr]], _SocketProvider[T_SockAddr]) - removed:
class SocketStream(Generic[T_SockAddr], ByteStream, _SocketProvider[T_SockAddr]) - removed:
class UDPSocket(UnreliableObjectStream[UDPPacketType], _SocketProvider[IPSockAddrType]) - removed:
field SocketAttribute.family: AddressFamily - removed:
field SocketAttribute.local_address: SockAddrType - removed:
field SocketAttribute.local_port: int - removed:
field SocketAttribute.raw_socket: SocketType - removed:
field SocketAttribute.remote_address: SockAddrType - removed:
field SocketAttribute.remote_port: int - removed:
variable IPAddressType - removed:
variable IPSockAddrType - removed:
variable SockAddrType - removed:
variable T_Retval - removed:
variable T_SockAddr - removed:
variable UDPPacketType
- removed:
async method ByteReceiveStream.receive(max_bytes: int=…) -> bytes - removed:
async method ByteSendStream.send(item: bytes) -> None - removed:
async method ByteStream.send_eof() -> None - removed:
async method Listener.serve(handler: Callable[[T_Stream], Any], task_group: Optional[TaskGroup]=…) -> None - removed:
async method ObjectStream.send_eof() -> None - removed:
async method UnreliableObjectReceiveStream.receive() -> T_Item - removed:
async method UnreliableObjectSendStream.send(item: T_Item) -> None - removed:
class ByteReceiveStream(AsyncResource, TypedAttributeProvider) - removed:
class ByteSendStream(AsyncResource, TypedAttributeProvider) - removed:
class ByteStream(ByteReceiveStream, ByteSendStream) - removed:
class Listener(Generic[T_Stream], AsyncResource, TypedAttributeProvider) - removed:
class ObjectReceiveStream(Generic[T_Item], UnreliableObjectReceiveStream[T_Item]) - removed:
class ObjectSendStream(Generic[T_Item], UnreliableObjectSendStream[T_Item]) - removed:
class ObjectStream(Generic[T_Item], ObjectReceiveStream[T_Item], ObjectSendStream[T_Item], UnreliableObjectStream[T_Item]) - removed:
class UnreliableObjectReceiveStream(Generic[T_Item], AsyncResource, TypedAttributeProvider) - removed:
class UnreliableObjectSendStream(Generic[T_Item], AsyncResource, TypedAttributeProvider) - removed:
class UnreliableObjectStream(Generic[T_Item], UnreliableObjectReceiveStream[T_Item], UnreliableObjectSendStream[T_Item]) - removed:
variable AnyByteReceiveStream - removed:
variable AnyByteSendStream - removed:
variable AnyByteStream - removed:
variable AnyUnreliableByteReceiveStream - removed:
variable AnyUnreliableByteSendStream - removed:
variable AnyUnreliableByteStream - removed:
variable T_Item - removed:
variable T_Stream
- removed:
async method Process.wait() -> int - removed:
class Process(AsyncResource) - removed:
method Process.kill() -> None - removed:
method Process.send_signal(signal: int) -> None - removed:
method Process.terminate() -> None - removed:
property Process.pid -> int - removed:
property Process.returncode -> Optional[int] - removed:
property Process.stderr -> Optional[ByteReceiveStream] - removed:
property Process.stdin -> Optional[ByteSendStream] - removed:
property Process.stdout -> Optional[ByteReceiveStream]
- removed:
async method CapacityLimiter.acquire() -> None - removed:
async method CapacityLimiter.acquire_nowait() -> None - removed:
async method CapacityLimiter.acquire_on_behalf_of(borrower) -> None - removed:
async method CapacityLimiter.acquire_on_behalf_of_nowait(borrower) -> None - removed:
async method CapacityLimiter.release() -> None - removed:
async method CapacityLimiter.release_on_behalf_of(borrower) -> None - removed:
async method CapacityLimiter.set_total_tokens(value: float) -> None - removed:
async method Condition.acquire() -> None - removed:
async method Condition.notify(n: int=…) -> None - removed:
async method Condition.notify_all() -> None - removed:
async method Condition.release() -> None - removed:
async method Condition.wait() -> None - removed:
async method Event.set() -> None - removed:
async method Event.wait() -> bool - removed:
async method Lock.acquire() -> None - removed:
async method Lock.release() -> None - removed:
async method Semaphore.acquire() -> None - removed:
async method Semaphore.release() -> None - removed:
class CapacityLimiter - removed:
class Condition - removed:
class Event - removed:
class Lock - removed:
class Semaphore - removed:
method Condition.locked() -> bool - removed:
method Event.is_set() -> bool - removed:
method Lock.locked() -> bool - removed:
property CapacityLimiter.available_tokens -> float - removed:
property CapacityLimiter.borrowed_tokens -> int - removed:
property CapacityLimiter.total_tokens -> float - removed:
property Semaphore.value -> int - removed:
variable IPAddressType - removed:
variable T_Retval
- removed:
async method CancelScope.cancel() -> None - removed:
async method TaskGroup.spawn(func: Callable[..., Coroutine], *args, name=…) -> None - removed:
class CancelScope - removed:
class TaskGroup - removed:
field TaskGroup.cancel_scope: CancelScope - removed:
property CancelScope.cancel_called -> bool - removed:
property CancelScope.deadline -> float - removed:
property CancelScope.shield -> bool - removed:
variable T_Retval
- removed:
async method BlockingPortal.sleep_until_stopped() -> None - removed:
async method BlockingPortal.stop(cancel_remaining: bool=…) -> None - removed:
class BlockingPortal - removed:
constructor BlockingPortal() - removed:
method BlockingPortal.call(func: Callable[..., Coroutine[Any, Any, T_Retval]], *args) -> T_Retval | (func: Callable[..., T_Retval], *args) -> T_Retval - removed:
method BlockingPortal.spawn_task(func: Callable[..., Coroutine], *args) -> Future - removed:
method BlockingPortal.stop_from_external_thread(cancel_remaining: bool=…) -> None - removed:
method BlockingPortal.wrap_async_context_manager(cm: AsyncContextManager[T_co]) -> ContextManager[T_co] - removed:
variable T_Retval - removed:
variable T_co
- added:
async method BlockingPortal.sleep_until_stopped() -> None - added:
async method BlockingPortal.stop(cancel_remaining: bool=…) -> None - added:
class BlockingPortal - added:
constructor BlockingPortal() -> None - added:
function create_blocking_portal() -> BlockingPortal - added:
function run(func: Callable[..., Awaitable[T_Retval]], *args: object) -> T_Retval - added:
function run_async_from_thread(func: Callable[..., Awaitable[T_Retval]], *args: object) -> T_Retval - added:
function run_sync(func: Callable[..., T_Retval], *args: object) -> T_Retval - added:
function run_sync_from_thread(func: Callable[..., T_Retval], *args: object) -> T_Retval - added:
function start_blocking_portal(backend: str=…, backend_options: dict[str, Any] | None=…) -> Generator[BlockingPortal, Any, None] - added:
method BlockingPortal.call(func: Callable[..., Awaitable[T_Retval]], *args: object) -> T_Retval | (func: Callable[..., T_Retval], *args: object) -> T_Retval - added:
method BlockingPortal.spawn_task(func: Callable[..., Awaitable[T_Retval]], *args: object, name: object=…) -> Future[T_Retval] | (func: Callable[..., T_Retval], *args: object, name: object=…) -> Future[T_Retval] - added:
method BlockingPortal.start_task(func: Callable[..., Awaitable[Any]], *args: object, name: object=…) -> tuple[Future[Any], Any] - added:
method BlockingPortal.start_task_soon(func: Callable[..., Awaitable[T_Retval]], *args: object, name: object=…) -> Future[T_Retval] | (func: Callable[..., T_Retval], *args: object, name: object=…) -> Future[T_Retval] - added:
method BlockingPortal.wrap_async_context_manager(cm: AsyncContextManager[T_co]) -> ContextManager[T_co] - added:
variable T_Retval - added:
variable T_co
- added:
async function cancel_shielded_checkpoint() -> None - added:
async function checkpoint() -> None - added:
async function checkpoint_if_cancelled() -> None - added:
class RunVar(Generic[T]) - added:
class RunvarToken(Generic[T]) - added:
constructor RunVar(name: str, default: T | Literal[_NoValueSet.NO_VALUE_SET]=…) - added:
constructor RunvarToken(var: RunVar[T], value: T | Literal[_NoValueSet.NO_VALUE_SET]) - added:
field RunVar.NO_VALUE_SET: Literal[_NoValueSet.NO_VALUE_SET] - added:
function current_token() -> object - added:
method RunVar.get(default: D) -> T | D | () -> T - added:
method RunVar.reset(token: RunvarToken[T]) -> None - added:
method RunVar.set(value: T) -> RunvarToken[T] - added:
variable D - added:
variable T
- changed:
function anyio_backend(request) → function anyio_backend(request: Any) -> Any - changed:
function anyio_backend_name(anyio_backend) -> str → function anyio_backend_name(anyio_backend: Any) -> str - changed:
function anyio_backend_options(anyio_backend) -> Dict[str, Any] → function anyio_backend_options(anyio_backend: Any) -> dict[str, Any] - changed:
function extract_backend_and_options(backend) -> Tuple[str, Dict[str, Any]] → function extract_backend_and_options(backend: object) -> tuple[str, dict[str, Any]] - changed:
function get_runner(backend_name: str, backend_options: Dict[str, Any]) -> Iterator[TestRunner] → function get_runner(backend_name: str, backend_options: dict[str, Any]) -> Generator[TestRunner, object, None] - changed:
function pytest_configure(config) → function pytest_configure(config: Any) -> None - changed:
function pytest_fixture_setup(fixturedef, request) → function pytest_fixture_setup(fixturedef: Any, request: Any) -> None - changed:
function pytest_pycollect_makeitem(collector, name, obj) → function pytest_pycollect_makeitem(collector: Any, name: Any, obj: Any) -> None - changed:
function pytest_pyfunc_call(pyfuncitem) → function pytest_pyfunc_call(pyfuncitem: Any) -> bool | None
- removed:
property BufferedByteReceiveStream.extra_attributes - added:
property BufferedByteReceiveStream.extra_attributes -> Mapping[Any, Callable[[], Any]]
- added:
async method FileReadStream.receive(max_bytes: int=…) -> bytes - added:
async method FileReadStream.seek(position: int, whence: int=…) -> int - added:
async method FileReadStream.tell() -> int - added:
async method FileWriteStream.send(item: bytes) -> None - added:
async static method FileReadStream.from_path(path: str | PathLike[str]) -> FileReadStream - added:
async static method FileWriteStream.from_path(path: str | PathLike[str], append: bool=…) -> FileWriteStream - added:
class FileReadStream(_BaseFileStream, ByteReceiveStream) - added:
class FileStreamAttribute(TypedAttributeSet) - added:
class FileWriteStream(_BaseFileStream, ByteSendStream) - added:
field FileStreamAttribute.file: BinaryIO - added:
field FileStreamAttribute.fileno: int - added:
field FileStreamAttribute.path: Path
- changed:
async method MemoryObjectReceiveStream.receive() -> T_Item → async method MemoryObjectReceiveStream.receive() -> T_co - changed:
async method MemoryObjectReceiveStream.receive_nowait() -> T_Item → method MemoryObjectReceiveStream.receive_nowait() -> T_co - changed:
async method MemoryObjectSendStream.send(item: T_Item) -> None → async method MemoryObjectSendStream.send(item: T_contra) -> None - changed:
async method MemoryObjectSendStream.send_nowait(item: T_Item) -> None → method MemoryObjectSendStream.send_nowait(item: T_contra) -> DeprecatedAwaitable - changed:
class MemoryObjectReceiveStream(Generic[T_Item], ObjectReceiveStream[T_Item]) → class MemoryObjectReceiveStream(Generic[T_co], ObjectReceiveStream[T_co]) - changed:
class MemoryObjectSendStream(Generic[T_Item], ObjectSendStream[T_Item]) → class MemoryObjectSendStream(Generic[T_contra], ObjectSendStream[T_contra]) - changed:
field MemoryObjectStreamState.buffer: Deque[T_Item] → field MemoryObjectStreamState.buffer: deque[T_Item] - changed:
field MemoryObjectStreamState.waiting_receivers: OrderedDict[Event, List[T_Item]] → field MemoryObjectStreamState.waiting_receivers: OrderedDict[Event, list[T_Item]] - changed:
method MemoryObjectReceiveStream.clone() -> MemoryObjectReceiveStream → method MemoryObjectReceiveStream.clone() -> MemoryObjectReceiveStream[T_co] - changed:
method MemoryObjectSendStream.clone() -> MemoryObjectSendStream → method MemoryObjectSendStream.clone() -> MemoryObjectSendStream[T_contra] - added:
class MemoryObjectStreamStatistics(NamedTuple) - added:
field MemoryObjectStreamStatistics.current_buffer_used: int - added:
field MemoryObjectStreamStatistics.max_buffer_size: float - added:
field MemoryObjectStreamStatistics.open_receive_streams: int - added:
field MemoryObjectStreamStatistics.open_send_streams: int - added:
field MemoryObjectStreamStatistics.tasks_waiting_receive: int - added:
field MemoryObjectStreamStatistics.tasks_waiting_send: int - added:
method MemoryObjectReceiveStream.close() -> None - added:
method MemoryObjectReceiveStream.statistics() -> MemoryObjectStreamStatistics - added:
method MemoryObjectSendStream.close() -> None - added:
method MemoryObjectSendStream.statistics() -> MemoryObjectStreamStatistics - added:
method MemoryObjectStreamState.statistics() -> MemoryObjectStreamStatistics - added:
variable T_co - added:
variable T_contra
- removed:
property MultiListener.extra_attributes - removed:
property StapledByteStream.extra_attributes - removed:
property StapledObjectStream.extra_attributes - changed:
async method MultiListener.serve(handler: Callable[[T_Stream], Any], task_group: Optional[TaskGroup]=…) -> None → async method MultiListener.serve(handler: Callable[[T_Stream], Any], task_group: TaskGroup | None=…) -> None - added:
property MultiListener.extra_attributes -> Mapping[Any, Callable[[], Any]] - added:
property StapledByteStream.extra_attributes -> Mapping[Any, Callable[[], Any]] - added:
property StapledObjectStream.extra_attributes -> Mapping[Any, Callable[[], Any]]
- removed:
property TextReceiveStream.extra_attributes - removed:
property TextSendStream.extra_attributes - removed:
property TextStream.extra_attributes - added:
property TextReceiveStream.extra_attributes -> Mapping[Any, Callable[[], Any]] - added:
property TextSendStream.extra_attributes -> Mapping[Any, Callable[[], Any]] - added:
property TextStream.extra_attributes -> Mapping[Any, Callable[[], Any]]
- removed:
property TLSListener.extra_attributes - removed:
property TLSStream.extra_attributes - changed:
async method TLSListener.serve(handler: Callable[[TLSStream], Any], task_group: Optional[TaskGroup]=…) -> None → async method TLSListener.serve(handler: Callable[[TLSStream], Any], task_group: TaskGroup | None=…) -> None - changed:
async method TLSStream.unwrap() -> Tuple[AnyByteStream, bytes] → async method TLSStream.unwrap() -> tuple[AnyByteStream, bytes] - changed:
async static method TLSStream.wrap(transport_stream: AnyByteStream, *, server_side: Optional[bool]=…, hostname: Optional[str]=…, ssl_context: Optional[ssl.SSLContext]=…, standard_compatible: bool=…) -> TLSStream → async static method TLSStream.wrap(transport_stream: AnyByteStream, *, server_side: bool | None=…, hostname: str | None=…, ssl_context: ssl.SSLContext | None=…, standard_compatible: bool=…) -> TLSStream - changed:
field TLSAttribute.alpn_protocol: Optional[str] → field TLSAttribute.alpn_protocol: str | None - changed:
field TLSAttribute.cipher: Tuple[str, str, int] → field TLSAttribute.cipher: tuple[str, str, int] - changed:
field TLSAttribute.peer_certificate: Optional[Dict[str, Union[str, tuple]]] → field TLSAttribute.peer_certificate: dict[str, str | _PCTRTTT | _PCTRTT] | None - changed:
field TLSAttribute.peer_certificate_binary: Optional[bytes] → field TLSAttribute.peer_certificate_binary: bytes | None - changed:
field TLSAttribute.shared_ciphers: List[Tuple[str, str, int]] → field TLSAttribute.shared_ciphers: list[tuple[str, str, int]] | None - changed:
field TLSListener.listener: Listener → field TLSListener.listener: Listener[Any] - added:
property TLSListener.extra_attributes -> Mapping[Any, Callable[[], Any]] - added:
property TLSStream.extra_attributes -> Mapping[Any, Callable[[], Any]]
- added:
async function run_sync(func: Callable[..., T_Retval], *args: object, cancellable: bool=…, limiter: CapacityLimiter | None=…) -> T_Retval - added:
function current_default_process_limiter() -> CapacityLimiter - added:
function process_worker() -> None - added:
variable T_Retval - added:
variable WORKER_MAX_IDLE_TIME
- added:
async function run_sync(func: Callable[..., T_Retval], *args: object, cancellable: bool=…, limiter: CapacityLimiter | None=…) -> T_Retval - added:
async function run_sync_in_worker_thread(func: Callable[..., T_Retval], *args: object, cancellable: bool=…, limiter: CapacityLimiter | None=…) -> T_Retval - added:
function current_default_thread_limiter() -> CapacityLimiter - added:
function current_default_worker_thread_limiter() -> CapacityLimiter - added:
variable T_Retval