feat: add gevent async env support

Signed-off-by: Gabor Boros <[email protected]>

Author: gabor-boros

poetry.lock

@@ -54,6 +54,7 @@ pyyaml = "^6.0.2"
 
 twisted = { version = "^25.5", optional = true }
 tornado = { version = "^6.5", optional = true }
+gevent = { version = "^25.5", optional = true }
 
 [tool.poetry.group.dev.dependencies]
 black = "^25.1"
@@ -68,9 +69,10 @@ pytest-twisted = "^1.14"
 pytest-asyncio = "^0.25"
 
 [tool.poetry.extras]
-all = ["twisted", "tornado"]
+all = ["twisted", "tornado", "gevent"]
 twisted = ["twisted"]
 tornado = ["tornado"]
+gevent = ["gevent"]
 
 [tool.black]
 target-version = ['py312']

pyproject.toml

@@ -257,8 +257,10 @@ def set_loop_type(self, library=None) -> None:
             library = None
 
         if library == "gevent":
-            warnings.warn(f"{library} is not yet supported, using the default one")
-            library = None
+            # pylint: disable=import-outside-toplevel
+            from rethinkdb.net_gevent import Connection as GeventConnection
+
+            self.connection_type = GeventConnection
 
         if library == "tornado":
             # pylint: disable=import-outside-toplevel

rethinkdb/__init__.py

@@ -247,16 +247,16 @@ def query_runner(description, query):
             logger.info("Starting data import...")
             try:
                 import_tables(import_options, sources)
-            except RuntimeError as ex:
+            except RuntimeError as exc:
                 if options.get("debug", False):
                     traceback.print_exc()
 
-                if str(ex) == "Warnings occurred during import":
+                if str(exc) == "Warnings occurred during import":
                     raise RuntimeError(
                         "Warning: import did not create some secondary indexes."
                     )
                 else:
-                    error_string = str(ex)
+                    error_string = str(exc)
                     if error_string.startswith("Error: "):
                         error_string = error_string[len("Error: ") :]
                     raise RuntimeError(f"Error: import failed: {error_string}")
@@ -433,8 +433,8 @@ def cmd_restore(
     try:
         do_restore(options)
         return 0
-    except RuntimeError as ex:
-        logger.error("Restore failed: %s", ex)
+    except RuntimeError as exc:
+        logger.error("Restore failed: %s", exc)
         return 1