Upgrading pyzmq 25 to 26
Unknown25.1.2 → 26.4.0Other1
Fetching 18 releases from GitHub…15 / 18
UnknownUpgrade verdict
DepDelta is still reading the notes for 3 of 18 releases, so breaking changes can't be ruled out yet.
In plain terms
- DepDelta is still reading the release notes in this range, so it can't rule out breaking changes yet.
- This page updates as the notes come in.
Must act Still reading release notes
DepDelta is still reading the release notes in this range. This updates as they come in.
Python requirement changed in 26.3.0: >=3.6 → >=3.8.
API changes
Generated by DepDelta from published Python source. Not mixed with prose notes.
- removed:
export device - changed:
function get_includes() -> List[str] → function get_includes() -> list[str] - changed:
function get_library_dirs() -> List[str] → function get_library_dirs() -> list[str]
- added:
constructor Context(io_threads: int | _zmq.Context=…, shadow: _zmq.Context | int=…) -> None
- removed:
function device(device_type: int, frontend: Socket, backend: Optional[Socket]=…) -> int - changed:
constructor Frame(data: Any=…, track: bool=…, copy: Optional[bool]=…, copy_threshold: Optional[int]=…) → constructor Frame(data: Any=…, track: bool=…, copy: bool | None=…, copy_threshold: int | None=…) - changed:
constructor Socket(context: Optional[Context]=…, socket_type: int=…, shadow: int=…, copy_threshold: Optional[int]=…) -> None → constructor Socket(context: Context | None=…, socket_type: int=…, shadow: int=…, copy_threshold: int | None=…) -> None - changed:
function curve_keypair() -> Tuple[bytes, bytes] → function curve_keypair() -> tuple[bytes, bytes] - changed:
function proxy(frontend: Socket, backend: Socket, capture: Optional[Socket]=…) -> int → function proxy(frontend: Socket, backend: Socket, capture: Socket | None=…) -> int - changed:
function proxy_steerable(frontend: Socket, backend: Socket, capture: Optional[Socket]=…, control: Optional[Socket]=…) -> int → function proxy_steerable(frontend: Socket, backend: Socket, capture: Socket | None=…, control: Socket | None=…) -> int - changed:
function strerror(errno: Optional[int]=…) -> str → function strerror(errno: int | None=…) -> str - changed:
function zmq_poll(sockets: List[Any], timeout: Optional[int]=…) -> List[Tuple[Socket, int]] → function zmq_poll(sockets: list[Any], timeout: int | None=…) -> list[tuple[Socket, int]] - changed:
function zmq_version_info() -> Tuple[int, int, int] → function zmq_version_info() -> tuple[int, int, int] - changed:
method Context.get(option: int) -> Union[int, bytes, str] → method Context.get(option: int) -> int | bytes | str - changed:
method Context.set(option: int, value: Union[int, bytes, str]) -> None → method Context.set(option: int, value: int | bytes | str) -> None - changed:
method Frame.get(option: int) -> Union[int, _bytestr, str] → method Frame.get(option: int) -> int | _bytestr | str - changed:
method Frame.set(option: int, value: Union[int, _bytestr, str]) -> None → method Frame.set(option: int, value: int | _bytestr | str) -> None - changed:
method Socket.close(linger: Optional[int]=…) -> None → method Socket.close(linger: int | None=…) -> None - changed:
method Socket.get(option: int) -> Union[int, bytes, str] → method Socket.get(option: int) -> int | bytes | str - changed:
method Socket.monitor(addr: Optional[str], events: int) -> None → method Socket.monitor(addr: str | None, events: int) -> None - changed:
method Socket.recv(flags: int=…, *, copy: Literal[False], track: bool=…) -> zmq.Frame | (flags: int=…, *, copy: Literal[True], track: bool=…) -> bytes | (flags: int=…, track: bool=…) -> bytes | (flags: Optional[int]=…, copy: bool=…, track: Optional[bool]=…) -> Union[zmq.Frame, bytes] → method Socket.recv(flags: int=…, *, copy: Literal[False], track: bool=…) -> zmq.Frame | (flags: int=…, *, copy: Literal[True], track: bool=…) -> bytes | (flags: int=…, track: bool=…) -> bytes | (flags: int | None=…, copy: bool=…, track: bool | None=…) -> zmq.Frame | bytes - changed:
method Socket.send(data: Any, flags: int=…, copy: bool=…, track: bool=…) -> Optional[zmq.MessageTracker] → method Socket.send(data: Any, flags: int=…, copy: bool=…, track: bool=…) -> zmq.MessageTracker | None - changed:
method Socket.set(option: int, value: Union[int, bytes, str]) -> None → method Socket.set(option: int, value: int | bytes | str) -> None - added:
method Socket.recv_into(buf, /, *, nbytes: int=…, flags: int=…) -> int - added:
variable monitored_queue
- removed:
function device(device_type, frontend, backend)
- added:
method Socket.recv_into(buffer, /, *, nbytes: int=…, flags: int=…) -> int
- added:
export monitored_queue - added:
variable Message
- added:
class NormMode(IntEnum) - added:
class RouterNotify(IntEnum) - added:
field NormMode.CC - added:
field NormMode.CCE - added:
field NormMode.CCE_ECNONLY - added:
field NormMode.CCL - added:
field NormMode.FIXED - added:
field RouterNotify.CONNECT - added:
field RouterNotify.DISCONNECT - added:
field SocketOption.BUSY_POLL - added:
field SocketOption.HICCUP_MSG - added:
field SocketOption.NORM_BLOCK_SIZE - added:
field SocketOption.NORM_BUFFER_SIZE - added:
field SocketOption.NORM_MODE - added:
field SocketOption.NORM_NUM_AUTOPARITY - added:
field SocketOption.NORM_NUM_PARITY - added:
field SocketOption.NORM_PUSH - added:
field SocketOption.NORM_SEGMENT_SIZE - added:
field SocketOption.NORM_UNICAST_NACK - added:
field SocketOption.TOPICS_COUNT - added:
field SocketOption.XSUB_VERBOSE_UNSUBSCRIBE - added:
variable BUSY_POLL: int - added:
variable HICCUP_MSG: int - added:
variable NORM_BLOCK_SIZE: int - added:
variable NORM_BUFFER_SIZE: int - added:
variable NORM_CC: int - added:
variable NORM_CCE: int - added:
variable NORM_CCE_ECNONLY: int - added:
variable NORM_CCL: int - added:
variable NORM_FIXED: int - added:
variable NORM_MODE: int - added:
variable NORM_NUM_AUTOPARITY: int - added:
variable NORM_NUM_PARITY: int - added:
variable NORM_PUSH: int - added:
variable NORM_SEGMENT_SIZE: int - added:
variable NORM_UNICAST_NACK: int - added:
variable NOTIFY_CONNECT: int - added:
variable NOTIFY_DISCONNECT: int - added:
variable TOPICS_COUNT: int - added:
variable XSUB_VERBOSE_UNSUBSCRIBE: int
- removed:
export device
- removed:
function monitored_queue(in_socket, out_socket, mon_socket, in_prefix=…, out_prefix=…) - added:
variable monitored_queue - added:
variable monitored_queue: Callable
- changed:
constructor ZMQError(errno: Optional[int]=…, msg: Optional[str]=…) → constructor ZMQError(errno: int | None=…, msg: str | None=…) - changed:
field ZMQError.errno: Optional[int] → field ZMQError.errno: int | None - added:
field InterruptedSystemCall.strerror: str - added:
field ZMQError.strerror: str
- changed:
constructor ZMQStream(socket: zmq.Socket, io_loop: Optional[IOLoop]=…) → constructor ZMQStream(socket: zmq.Socket, io_loop: IOLoop | None=…) - changed:
method ZMQStream.close(linger: Optional[int]=…) -> None → method ZMQStream.close(linger: int | None=…) -> None - changed:
method ZMQStream.flush(flag: int=…, limit: Optional[int]=…) → method ZMQStream.flush(flag: int=…, limit: int | None=…) - changed:
method ZMQStream.on_recv(callback: Callable[[List[bytes]], Any]) -> None | (callback: Callable[[List[bytes]], Any], copy: Literal[True]) -> None | (callback: Callable[[List[zmq.Frame]], Any], copy: Literal[False]) -> None | (callback: Union[Callable[[List[zmq.Frame]], Any], Callable[[List[bytes]], Any]], copy: bool=…) → method ZMQStream.on_recv(callback: Callable[[list[bytes]], Any]) -> None | (callback: Callable[[list[bytes]], Any], copy: Literal[True]) -> None | (callback: Callable[[list[zmq.Frame]], Any], copy: Literal[False]) -> None | (callback: Callable[[list[zmq.Frame]], Any] | Callable[[list[bytes]], Any], copy: bool=…) - changed:
method ZMQStream.on_recv_stream(callback: Callable[[ZMQStream, List[bytes]], Any]) -> None | (callback: Callable[[ZMQStream, List[bytes]], Any], copy: Literal[True]) -> None | (callback: Callable[[ZMQStream, List[zmq.Frame]], Any], copy: Literal[False]) -> None | (callback: Union[Callable[[ZMQStream, List[zmq.Frame]], Any], Callable[[ZMQStream, List[bytes]], Any]], copy: bool=…) → method ZMQStream.on_recv_stream(callback: Callable[[ZMQStream, list[bytes]], Any]) -> None | (callback: Callable[[ZMQStream, list[bytes]], Any], copy: Literal[True]) -> None | (callback: Callable[[ZMQStream, list[zmq.Frame]], Any], copy: Literal[False]) -> None | (callback: Callable[[ZMQStream, list[zmq.Frame]], Any] | Callable[[ZMQStream, list[bytes]], Any], copy: bool=…) - changed:
method ZMQStream.on_send(callback: Callable[[Sequence[Any], Optional[zmq.MessageTracker]], Any]) → method ZMQStream.on_send(callback: Callable[[Sequence[Any], zmq.MessageTracker | None], Any]) - changed:
method ZMQStream.on_send_stream(callback: Callable[[ZMQStream, Sequence[Any], Optional[zmq.MessageTracker]], Any]) → method ZMQStream.on_send_stream(callback: Callable[[ZMQStream, Sequence[Any], zmq.MessageTracker | None], Any]) - changed:
method ZMQStream.send_json(obj: Any, flags: int=…, callback: Optional[Callable]=…, **kwargs: Any) → method ZMQStream.send_json(obj: Any, flags: int=…, callback: Callable | None=…, **kwargs: Any) - changed:
method ZMQStream.send_multipart(msg: Sequence[Any], flags: int=…, copy: bool=…, track: bool=…, callback: Optional[Callable]=…, **kwargs: Any) -> None → method ZMQStream.send_multipart(msg: Sequence[Any], flags: int=…, copy: bool=…, track: bool=…, callback: Callable | None=…, **kwargs: Any) -> None - changed:
method ZMQStream.send_pyobj(obj: Any, flags: int=…, protocol: int=…, callback: Optional[Callable]=…, **kwargs: Any) → method ZMQStream.send_pyobj(obj: Any, flags: int=…, protocol: int=…, callback: Callable | None=…, **kwargs: Any) - changed:
method ZMQStream.send_string(u: str, flags: int=…, encoding: str=…, callback: Optional[Callable]=…, **kwargs: Any) → method ZMQStream.send_string(u: str, flags: int=…, encoding: str=…, callback: Callable | None=…, **kwargs: Any) - changed:
method ZMQStream.set_close_callback(callback: Optional[Callable]) → method ZMQStream.set_close_callback(callback: Callable | None)
- changed:
variable TIMEOS: Tuple → variable TIMEOS: tuple
- changed:
constructor PUBHandler(interface_or_socket: Union[str, zmq.Socket], context: Optional[zmq.Context]=…, root_topic: str=…) -> None → constructor PUBHandler(interface_or_socket: str | zmq.Socket, context: zmq.Context | None=…, root_topic: str=…) -> None
- changed:
class Context(ContextBase, AttributeSetter, Generic[ST]) → class Context(ContextBase, AttributeSetter, Generic[_SocketType]) - changed:
constructor Context(io_threads: int=…) | (io_threads: Context) | (*, shadow: Union[Context, int]) → constructor Context(io_threads: int=…) | (io_threads: Context, /) | (*, shadow: Context | int) - changed:
field Context.sockopts: Dict[int, Any] → field Context.sockopts: dict[int, Any] - changed:
method Context.destroy(linger: Optional[int]=…) -> None → method Context.destroy(linger: int | None=…) -> None - changed:
method Context.socket(socket_type: int, socket_class: Optional[Callable[[T, int], ST]]=…, **kwargs: Any) -> ST → method Context.socket(socket_type: int, socket_class: Callable[[_ContextType, int], _SocketType] | None=…, **kwargs: Any) -> _SocketType - changed:
static method Context.instance(io_threads: int=…) -> T → static method Context.instance(io_threads: int=…) -> _ContextType - changed:
static method Context.shadow(address: Union[int, Context]) -> T → static method Context.shadow(address: int | zmq.Context) -> _ContextType - changed:
static method Context.shadow_pyczmq(ctx: Any) -> T → static method Context.shadow_pyczmq(ctx: Any) -> _ContextType - added:
variable SyncContext: TypeAlias
- changed:
field Poller.sockets: List[Tuple[Any, int]] → field Poller.sockets: list[tuple[Any, int]] - changed:
function select(rlist: List, wlist: List, xlist: List, timeout: Optional[float]=…) → function select(rlist: list, wlist: list, xlist: list, timeout: float | None=…) -> tuple[list, list, list] - changed:
method Poller.poll(timeout: Optional[int]=…) -> List[Tuple[Any, int]] → method Poller.poll(timeout: int | None=…) -> list[tuple[Any, int]]
- changed:
class Socket(SocketBase, AttributeSetter, Generic[ST]) → class Socket(SocketBase, AttributeSetter, Generic[SocketReturnType]) - changed:
constructor Socket(ctx_or_socket: zmq.Context, socket_type: int, *, copy_threshold: Optional[int]=…) | (*, shadow: Union[Socket, int], copy_threshold: Optional[int]=…) | (ctx_or_socket: Socket) → constructor Socket(ctx_or_socket: zmq.Context, socket_type: int, *, copy_threshold: int | None=…) | (*, shadow: Socket | int, copy_threshold: int | None=…) | (ctx_or_socket: Socket) - changed:
method Socket.bind(addr: str) -> _SocketContext[T] → method Socket.bind(addr: str) -> _SocketContext[_SocketType] - changed:
method Socket.connect(addr: str) -> _SocketContext[T] → method Socket.connect(addr: str) -> _SocketContext[_SocketType] - changed:
method Socket.get_monitor_socket(events: Optional[int]=…, addr: Optional[str]=…) -> T → method Socket.get_monitor_socket(events: int | None=…, addr: str | None=…) -> _SocketType - changed:
method Socket.poll(timeout=…, flags=…) -> int → method Socket.poll(timeout: int | None=…, flags: int=…) -> int - changed:
method Socket.recv_json(flags: int=…, **kwargs) -> Union[List, str, int, float, Dict] → method Socket.recv_json(flags: int=…, **kwargs) -> _JSONType - changed:
method Socket.recv_multipart(flags: int=…, *, copy: Literal[True], track: bool=…) -> List[bytes] | (flags: int=…, *, copy: Literal[False], track: bool=…) -> List[zmq.Frame] | (flags: int=…, *, track: bool=…) -> List[bytes] | (flags: int=…, copy: bool=…, track: bool=…) -> Union[List[zmq.Frame], List[bytes]] → method Socket.recv_multipart(flags: int=…, *, copy: Literal[True], track: bool=…) -> list[bytes] | (flags: int=…, *, copy: Literal[False], track: bool=…) -> list[zmq.Frame] | (flags: int=…, *, track: bool=…) -> list[bytes] | (flags: int=…, copy: bool=…, track: bool=…) -> list[zmq.Frame] | list[bytes] - changed:
method Socket.send(data: Any, flags: int=…, copy: bool=…, *, track: Literal[True], routing_id: Optional[int]=…, group: Optional[str]=…) -> zmq.MessageTracker | (data: Any, flags: int=…, copy: bool=…, *, track: Literal[False], routing_id: Optional[int]=…, group: Optional[str]=…) -> None | (data: Any, flags: int=…, *, copy: bool=…, routing_id: Optional[int]=…, group: Optional[str]=…) -> None | (dat… → method Socket.send(data: Any, flags: int=…, copy: bool=…, *, track: Literal[True], routing_id: int | None=…, group: str | None=…) -> zmq.MessageTracker | (data: Any, flags: int=…, copy: bool=…, *, track: Literal[False], routing_id: int | None=…, group: str | None=…) -> None | (data: Any, flags: int=…, *, copy: bool=…, routing_id: int | None=…, group: str | None=…) -> None | (data: Any, flags: int… - changed:
method Socket.send_pyobj(obj: Any, flags: int=…, protocol: int=…, **kwargs) -> Optional[zmq.Frame] → method Socket.send_pyobj(obj: Any, flags: int=…, protocol: int=…, **kwargs) -> zmq.Frame | None - changed:
method Socket.send_string(u: str, flags: int=…, copy: bool=…, encoding: str=…, **kwargs) -> Optional[zmq.Frame] → method Socket.send_string(u: str, flags: int=…, copy: bool=…, encoding: str=…, **kwargs) -> zmq.Frame | None - changed:
method Socket.subscribe(topic: Union[str, bytes]) -> None → method Socket.subscribe(topic: str | bytes) -> None - changed:
method Socket.unsubscribe(topic: Union[str, bytes]) -> None → method Socket.unsubscribe(topic: str | bytes) -> None - changed:
static method Socket.shadow(address: Union[int, zmq.Socket]) -> T → static method Socket.shadow(address: int | zmq.Socket) -> _SocketType - added:
variable SyncSocket: TypeAlias
- changed:
constructor MessageTracker(*towatch: Tuple[Union[MessageTracker, Event, Frame]]) → constructor MessageTracker(*towatch: tuple[MessageTracker | Event | Frame]) - changed:
field MessageTracker.events: Set[Event] → field MessageTracker.events: set[Event] - changed:
field MessageTracker.peers: Set[MessageTracker] → field MessageTracker.peers: set[MessageTracker] - changed:
method MessageTracker.wait(timeout: Union[float, int]=…) → method MessageTracker.wait(timeout: float | int=…)
- changed:
function pyzmq_version_info() -> Union[Tuple[int, int, int], Tuple[int, int, int, float]] → function pyzmq_version_info() -> tuple[int, int, int] | tuple[int, int, int, float]
- changed:
function loads(s: Union[bytes, str], **kwargs) -> Union[Dict, List, str, int, float] → function loads(s: bytes | str, **kwargs) -> dict | list | str | int | float
- changed:
function parse_monitor_message(msg: List[bytes]) -> _MonitorMessage → function parse_monitor_message(msg: list[bytes]) -> _MonitorMessage
- changed:
constructor allow_interrupt(action: Optional[Callable[[], Any]]=…) -> None → constructor allow_interrupt(action: Callable[[], Any] | None=…) -> None