Fix incorrect name of starmap function

2026-09-24 16:54:05 +00:00 · 2026-09-22 16:16:52 -04:00
parent 084cda09d1
commit 6f8920d47e
1 changed files with 1 additions and 1 deletions
@@ -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