From 6f8920d47ee4896667b3e3f4c397d6aa140022e6 Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Tue, 22 Sep 2026 16:16:52 -0400 Subject: [PATCH] Fix incorrect name of starmap function --- .../confluent/plugins/hardwaremanagement/cooltera.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/confluent_server/confluent/plugins/hardwaremanagement/cooltera.py b/confluent_server/confluent/plugins/hardwaremanagement/cooltera.py index b5238577..6064d234 100644 --- a/confluent_server/confluent/plugins/hardwaremanagement/cooltera.py +++ b/confluent_server/confluent/plugins/hardwaremanagement/cooltera.py @@ -178,7 +178,7 @@ async def retrieve(nodes, element, configmanager, inputdata): taskargs = [] for node in nodes: taskargs.append((element, node, configmanager)) - gp = tasks.starmap(read_sensors, taskargs) + gp = tasks.task_starmap(read_sensors, taskargs) async for rsp in gp: for datum in rsp: yield datum