Move AsyncMinHashLSH from experimental to datasketch.aio

.github/workflows/test-cassandra.yml

@@ -1,11 +1,10 @@
 name: Test Cassandra
 
 on:
-  workflow_run:
-    workflows:
-      - Test
-    types:
-      - completed
+  push:
+    branches: [master]
+  pull_request:
+    branches: [master]
 
 jobs:
   build:

.github/workflows/test-mongo.yml

@@ -1,11 +1,10 @@
 name: Test Mongo
 
 on:
-  workflow_run:
-    workflows:
-      - Test
-    types:
-      - completed
+  push:
+    branches: [master]
+  pull_request:
+    branches: [master]
 
 jobs:
   build:

.github/workflows/test-redis.yml

@@ -1,11 +1,10 @@
 name: Test Redis
 
 on:
-  workflow_run:
-    workflows:
-      - Test
-    types:
-      - completed
+  push:
+    branches: [master]
+  pull_request:
+    branches: [master]
 
 jobs:
   build:

datasketch/__init__.py

@@ -23,9 +23,15 @@
 WeightedMinHashLSH = MinHashLSH
 WeightedMinHashLSHForest = MinHashLSHForest
 
+# Optional async export (requires motor or redis.asyncio)
+try:
+    from datasketch.aio import AsyncMinHashLSH
+except ImportError:
+    AsyncMinHashLSH = None  # type: ignore[misc,assignment]
 
 __all__ = [
     "HNSW",
+    "AsyncMinHashLSH",
     "HyperLogLog",
     "HyperLogLogPlusPlus",
     "LeanMinHash",

datasketch/aio/__init__.py

@@ -0,0 +1,36 @@
+"""Async MinHash LSH module.
+
+This module provides asynchronous implementations of MinHash LSH for use with
+async storage backends like MongoDB (via motor) and Redis (via redis.asyncio).
+
+Example:
+    .. code-block:: python
+
+        from datasketch.aio import AsyncMinHashLSH
+        from datasketch import MinHash
+
+        async def main():
+            async with AsyncMinHashLSH(
+                storage_config={"type": "aiomongo", "mongo": {"host": "localhost", "port": 27017}},
+                threshold=0.5,
+                num_perm=128,
+                prepickle=True,  # Enable string keys
+            ) as lsh:
+                m = MinHash(num_perm=128)
+                m.update(b"data")
+                await lsh.insert("key", m)
+                result = await lsh.query(m)
+
+"""
+
+from datasketch.aio.lsh import (
+    AsyncMinHashLSH,
+    AsyncMinHashLSHDeleteSession,
+    AsyncMinHashLSHInsertionSession,
+)
+
+__all__ = [
+    "AsyncMinHashLSH",
+    "AsyncMinHashLSHDeleteSession",
+    "AsyncMinHashLSHInsertionSession",
+]