Name the CluClient client

sdss · Dec 5, 2024 · bd8a3d3 · bd8a3d3
1 parent a0e4108
commit bd8a3d3
Show file tree

Hide file tree

Showing 3 changed files with 336 additions and 286 deletions.
diff --git a/pyproject.toml b/pyproject.toml
@@ -13,7 +13,7 @@ dependencies = [
     "sdsstools>=1.8.1",
     "fastapi[standard]>=0.112.0",
     "lvmgort>=1.1.2",
-    "lvmopstools[influxdb,kubernetes,schedule]>=0.4.1",
+    "lvmopstools[influxdb,kubernetes,schedule]>=0.4.4",
     "gunicorn>=22.0.0",
     "uvicorn[standard]>=0.24.0",
     "sdss-clu>=2.2.1",

diff --git a/src/lvmapi/tools/rabbitmq.py b/src/lvmapi/tools/rabbitmq.py
@@ -8,6 +8,8 @@
 
 from __future__ import annotations
 
+import uuid
+
 from typing import TYPE_CHECKING
 
 from lvmopstools.clu import CluClient, send_clu_command
@@ -23,6 +25,10 @@
 __all__ = ["CluClient", "send_clu_command", "ping_actors"]
 
 
+# CluClient is a singleton. Create a client with lvmapi name.
+CluClient(name=f"lvmapi-{uuid.uuid4()}")
+
+
 async def ping_actors(actors: list[str] | None = None):
     """Pings all actors and returns a list of replies."""