Skip gevent for python>=3.14

Author: jairhenrique

bin/dramatiq-gevent

@@ -1,13 +1,18 @@
 #!python
+import sys
+
+if sys.version_info >= (3, 14):
+    sys.stderr.write("error: gevent is not supported on Python 3.14 and later.")
+    sys.exit(1)
+
 try:
-    from gevent import monkey; monkey.patch_all()  # noqa
+    from gevent import monkey
+
+    monkey.patch_all()  # noqa
 except ImportError:
-    import sys
     sys.stderr.write("error: gevent is missing. Run `pip install gevent`.")
     sys.exit(1)
 
-import sys
-
 from dramatiq.cli import main
 
 if __name__ == "__main__":

dramatiq/threading.py

@@ -42,6 +42,9 @@
 
 def is_gevent_active():
     """Detect if gevent monkey patching is active."""
+    if python_version >= ("3", "14"):
+        return False
+
     try:
         from gevent import monkey
     except ImportError:  # pragma: no cover
@@ -74,7 +77,9 @@ def raise_thread_exception(thread_id, exception):
         _raise_thread_exception_cpython(thread_id, exception)
     else:
         message = "Setting thread exceptions (%s) is not supported for your current platform (%r)."
-        exctype = (exception if inspect.isclass(exception) else type(exception)).__name__
+        exctype = (
+            exception if inspect.isclass(exception) else type(exception)
+        ).__name__
         logger.critical(message, exctype, current_platform)
 
 
@@ -84,7 +89,11 @@ def _raise_thread_exception_cpython(thread_id, exception):
     exception = ctypes.py_object(exception)
     count = ctypes.pythonapi.PyThreadState_SetAsyncExc(thread_id, exception)
     if count == 0:
-        logger.critical("Failed to set exception (%s) in thread %r.", exctype, thread_id.value)
+        logger.critical(
+            "Failed to set exception (%s) in thread %r.", exctype, thread_id.value
+        )
     elif count > 1:  # pragma: no cover
-        logger.critical("Exception (%s) was set in multiple threads.  Undoing...", exctype)
+        logger.critical(
+            "Exception (%s) was set in multiple threads.  Undoing...", exctype
+        )
         ctypes.pythonapi.PyThreadState_SetAsyncExc(thread_id, ctypes.c_long(0))

setup.py

@@ -43,7 +43,7 @@ def rel(*xs):
 
 extra_dependencies = {
     "gevent": [
-        "gevent>=1.1",
+        "gevent>=1.1; python_version < '3.14'",
     ],
     "memcached": [
         "pylibmc>=1.5,<2.0",