Source code for weaviate.collections.cluster.async_

from weaviate.collections.cluster.executor import _ClusterExecutor
from weaviate.connect import executor
from weaviate.connect.v4 import ConnectionAsync


[docs] @executor.wrap("async") class _ClusterAsync(_ClusterExecutor[ConnectionAsync]): pass