Skip to content

Commit

Permalink
Fix CI/CD errors
Browse files Browse the repository at this point in the history
  • Loading branch information
steamraven committed Feb 4, 2025
1 parent 9513f5c commit 7d4ba7c
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 3 deletions.
5 changes: 3 additions & 2 deletions zmq/asyncio.py
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
from weakref import WeakKeyDictionary

import zmq as _zmq
from zmq import _future
from zmq import _future, Socket as _Socket
from zmq.backend import ZMQPoller

# registry of asyncio loop : selector thread
Expand Down Expand Up @@ -141,6 +141,7 @@ class Socket(_AsyncIO, _future._AsyncSocket):

_poller_class = Poller
_zmqpoller: ZMQPoller | None = None
_shadow_sock: _Socket

def _get_selector(self, io_loop=None):
if io_loop is None:
Expand Down Expand Up @@ -179,7 +180,7 @@ def _update_handler(self, state: int):
"""
if self._zmqpoller is not None:
self._zmqpoller.modify(self._shadow_sock, state)
super()._update_handler(state)
super()._update_handler(state) # type: ignore


Poller._socket_class = Socket
Expand Down
2 changes: 1 addition & 1 deletion zmq/sugar/socket.py
Original file line number Diff line number Diff line change
Expand Up @@ -395,7 +395,7 @@ def fileno(self) -> int:

.. versionadded:: 17.0
"""
return self.FD
return cast(int, self.FD) # FIXME: On windows this is not an int

def subscribe(self, topic: str | bytes) -> None:
"""Subscribe to a topic
Expand Down

0 comments on commit 7d4ba7c

Please sign in to comment.